This repository was archived by the owner on Jun 30, 2022. It is now read-only.
File tree Expand file tree Collapse file tree
google/cloud/dataflow/utils Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -242,8 +242,10 @@ def _add_argparse_args(cls, parser):
242242 help =
243243 ('Number of workers to use when executing the Dataflow job. If not '
244244 'set, the Dataflow service will use a reasonable default.' ))
245+ # TODO(silviuc): Remove --machine_type variant of the flag.
245246 parser .add_argument (
246- '--machine_type' ,
247+ '--worker_machine_type' , '--machine_type' ,
248+ dest = 'machine_type' ,
247249 default = None ,
248250 help = ('Machine type to create Dataflow worker VMs as. See '
249251 'https://cloud.google.com/compute/docs/machine-types '
@@ -257,8 +259,10 @@ def _add_argparse_args(cls, parser):
257259 help =
258260 ('Remote worker disk size, in gigabytes, or 0 to use the default size. '
259261 'If not set, the Dataflow service will use a reasonable default.' ))
262+ # TODO(silviuc): Remove --disk_type variant of the flag.
260263 parser .add_argument (
261- '--disk_type' ,
264+ '--worker_disk_type' , '--disk_type' ,
265+ dest = 'disk_type' ,
262266 default = None ,
263267 help = ('Specifies what type of persistent disk should be used.' ))
264268 parser .add_argument (
You can’t perform that action at this time.
0 commit comments