8SrSSKJr SSKJr SSKJr SSKJr SSKJr SSK J r SSK J r SS K Jr SS KJr \ R""\ R$R&\ R$R(5\ R*"S S \ R,555rg )z6Implementation of gcloud dataflow jobs cancel command.)absolute_import)division)unicode_literals)apis) exceptions)base) job_utils)log) console_ioc.\rSrSrSr\S5rSrSrg)Cancelz7Cancels all jobs that match the command line arguments.cP[R"USS9 URSSSS9 g)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.pyArgs Cancel.Args"s2V3/   c [R"U5HnUR(a[R"SSS9 [ R RURURURURS9 [RRSRUR55 M g![R adn[RRSRURUR"R$UR55 SnAGM"SnAff=f)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 rRun Cancel.Run0s ++D1 ::  # #}   MM JJ((&&  ( .55gmmDE2 % %   #V u}};;W=M=M   sB&CD>AD99D>N) __name__ __module__ __qualname____firstlineno____doc__ staticmethodrr2__static_attributes__r4rrr r s@   rr N)r9 __future__rrrgooglecloudsdk.api_lib.dataflowrgooglecloudsdk.api_lib.utilrgooglecloudsdk.callioper#googlecloudsdk.command_lib.dataflowr googlecloudsdk.corer googlecloudsdk.core.consoler ReleaseTracks ReleaseTrackBETAGADefaultUniverseOnlyCommandr r4rrrIsx=&'02(9#2D%%**D,=,=,@,@A+ T\\+ B+ r