refactor: remove disk provisioned IOPS and throughput arguments from WorkerOptions

Author: bambadiouf1

sdks/python/apache_beam/options/pipeline_options.py

@@ -1405,24 +1405,6 @@ def _add_argparse_args(cls, parser):
         dest='disk_type',
         default=None,
         help=('Specifies what type of persistent disk should be used.'))
-    parser.add_argument(
-        '--disk_provisioned_iops',
-        type=int,
-        default=None,
-        dest='disk_provisioned_iops',
-        help=(
-            'The provisioned IOPS of the disk. If not set, the Dataflow service'
-            ' will choose a reasonable default.'),
-    )
-    parser.add_argument(
-        '--disk_provisioned_throughput_mibps',
-        type=int,
-        default=None,
-        dest='disk_provisioned_throughput_mibps',
-        help=(
-            'The provisioned throughput of the disk in MiB/s. If not set, the'
-            ' Dataflow service will choose a reasonable default.'),
-    )
     parser.add_argument(
         '--worker_region',
         default=None,

sdks/python/apache_beam/options/pipeline_options_test.py

@@ -26,6 +26,8 @@
 
 import hamcrest as hc
 import mock
+from parameterized import parameterized
+
 from apache_beam.options.pipeline_options import CrossLanguageOptions
 from apache_beam.options.pipeline_options import DebugOptions
 from apache_beam.options.pipeline_options import GoogleCloudOptions
@@ -41,7 +43,6 @@
 from apache_beam.options.value_provider import StaticValueProvider
 from apache_beam.transforms.display import DisplayData
 from apache_beam.transforms.display_test import DisplayDataItemMatcher
-from parameterized import parameterized
 
 _LOGGER = logging.getLogger(__name__)
 
@@ -443,18 +444,12 @@ def test_worker_options(self):
         'abc',
         '--disk_type',
         'def',
-        '--disk_provisioned_iops',
-        '4000',
-        '--disk_provisioned_throughput_mibps',
-        '200',
         '--element_processing_timeout_minutes',
         '10',
     ])
     worker_options = options.view_as(WorkerOptions)
     self.assertEqual(worker_options.machine_type, 'abc')
     self.assertEqual(worker_options.disk_type, 'def')
-    self.assertEqual(worker_options.disk_provisioned_iops, 4000)
-    self.assertEqual(worker_options.disk_provisioned_throughput_mibps, 200)
     self.assertEqual(worker_options.element_processing_timeout_minutes, 10)
 
     options = PipelineOptions(