=SrSSKJr SSKJr SSKJr SSKJr SSKJr SSKJ r SSK J r \R"\RR\RR5"S S \R 55rg ) z>Implementation of gcloud dataflow jobs update-options command.)absolute_import)division)unicode_literals)apis)base) exceptions) job_utilsc.\rSrSrSr\S5rSrSrg) UpdateOptionsaUpdate pipeline options on-the-fly for running Dataflow jobs. This command can modify properties of running Dataflow jobs. Currently, only updating autoscaling settings for Streaming Engine jobs is supported. Adjust the autoscaling settings for Streaming Engine Dataflow jobs by providing at-least one of --min-num-workers or --max-num-workers or --worker-utilization-hint (or all 3), or --unset-worker-utilization-hint (which cannot be run at the same time as --worker-utilization-hint but works with the others). Allow a few minutes for the changes to take effect. Note that autoscaling settings can only be modified on-the-fly for Streaming Engine jobs. Attempts to modify batch job or Streaming Appliance jobs will fail. ## EXAMPLES Modify autoscaling settings to scale between 5-10 workers: $ {command} --min-num-workers=5 --max-num-workers=10 Require a job to use at least 2 workers: $ {command} --min-num-workers=2 Require a job to use at most 20 workers: $ {command} --max-num-workers=20 Adjust the hint of target worker utilization to 70% for horizontal autoscaling: $ {command} --worker-utilization-hint=0.7 "Unset" worker utilization hint so that horizontal scaling will rely on its default CPU utilization target: $ {command} --unset-worker-utilization-hint c[R"U5 URS[SS9 URS[SS9 URS[SS9 URSS S S 9 g ) z Register flags for this command.--min-num-workerszVLower-bound for autoscaling, between 1-1000. Only supported for streaming-engine jobs.)typehelp--max-num-workerszVUpper-bound for autoscaling, between 1-1000. Only supported for streaming-engine jobs.--worker-utilization-hintzTarget CPU utilization for autoscaling, ranging from 0.1 to 0.9. Only supported for streaming-engine jobs with autoscaling enabled.--unset-worker-utilization-hint store_truezUnset --worker-utilization-hint. This causes the job autoscaling to fall back to internal tunings if they exist, or otherwise use the default hint value.)actionrN)r ArgsForJobRef add_argumentintfloat)parsers +lib/surface/dataflow/jobs/update_options.pyArgsUpdateOptions.ArgsGsF#   &    &  #    ) G c  URcDURc7URc*UR(d[R "/SQS5eURb'UR(a[R "S5e[R"U5n[RRURURURURURURURS9$)zCalled when the user runs gcloud dataflow jobs update-options ... Args: args: all the arguments that were provided to this command invocation. Returns: The updated Job )rrrrz-You must provide at-least one field to updatezThe arguments --worker-utilization-hint and --unset-worker-utilization-hint are mutually exclusive (as the unset command will unset the given hint), and must be called separately.) project_id region_idmin_num_workersmax_num_workersworker_utilization_hintunset_worker_utilization_hint)r"r#r$r%rOneOfArgumentsRequiredExceptionConflictingArgumentsExceptionr ExtractJobRefrJobsr jobId projectIdlocation)selfargsjob_refs rRunUpdateOptions.Runns $  (  ( ( 022  6 6 :  $$0  . .  4 4  %%d+G 99 " " $$"",,,, $ < <&*&H&H # rN) __name__ __module__ __qualname____firstlineno____doc__ staticmethodrr0__static_attributes__r2rrr r s"(T$$L,rr N)r7 __future__rrrgooglecloudsdk.api_lib.dataflowrgooglecloudsdk.callioperr#googlecloudsdk.command_lib.dataflowr ReleaseTracks ReleaseTrackGABETACommandr r2rrrCshE&'0(.9D%%(($*;*;*@*@A~DLL~B~r