8dZddlmZddlmZddlmZddlmZddlmZddl m Z ddl m Z dd l mZdd lmZe j"e j$j&e j$j(e j*Gd d e j,Zy )z6Implementation of gcloud dataflow jobs cancel command.)absolute_import)division)unicode_literals)apis) exceptions)base) job_utils)log) console_ioc&eZdZdZedZdZy)Cancelz7Cancels all jobs that match the command line arguments.cZtj|d|jdddy)z Register flags for this command.+)nargsz--force store_truezForcibly cancels a Dataflow job. Regular cancel must have been attempted at least 30 minutes prior for a job to be force cancelled.)actionhelpN)r ArgsForJobRefs add_argument)parsers #lib/surface/dataflow/jobs/cancel.pyArgsz Cancel.Args"s2V3/   c xtj|D]} |jrtjddt j j|j|j|j|jtjjdj|jy#tj $rc}tjjdj|j|j"j$|jYd}~d}~wwxYw)zThis is what gets called when the user runs this command. Args: args: all the arguments that were provided to this command invocation. zeForce cancellation will leak VMs the cancelled Dataflow job created that must be manually cleaned up.T)message cancel_on_no) project_id region_idzCancelled job [{0}]zFailed to cancel job [{0}]: {1} Ensure that you have permission to access the job and that the `--region` flag, {2}, matches the job's region.N)r ExtractJobRefsforcer PromptContinuerJobsr jobId projectIdlocationr statusPrintformatr HttpExceptionpayloadstatus_message)selfargsjob_referrors rRunz Cancel.Run0s ++D1 ::  # #}   MM JJ((&&  ( .55gmmDE2 % %   #V u}};;W=M=M   sB&CD9AD44D9N)__name__ __module__ __qualname____doc__ staticmethodrr0rrr r s@   rr N)r4 __future__rrrgooglecloudsdk.api_lib.dataflowrgooglecloudsdk.api_lib.utilrgooglecloudsdk.callioper#googlecloudsdk.command_lib.dataflowr googlecloudsdk.corer googlecloudsdk.core.consoler ReleaseTracks ReleaseTrackBETAGADefaultUniverseOnlyCommandr r6rrrDsz=&'02(9#2D%%**D,=,=,@,@A+ T\\+ B+ r