,SrSSKJr SSKJr SSKJr SSKJr SSKJr SSK J r SSK J r SS K Jr \ R"\ R R"\ R R$5\ R&"S S \ R(555rg ) z6Implementation of gcloud dataflow jobs drain command. )absolute_import)division)unicode_literals)apis) exceptions)base) job_utils)logc.\rSrSrSr\S5rSrSrg)DrainaDrains all jobs that match the command line arguments. Once Drain is triggered, the pipeline will stop accepting new inputs. The input watermark will be advanced to infinity. Elements already in the pipeline will continue to be processed. Drained jobs can safely be cancelled. c.[R"USS9 g)z Register flags for this command.+)nargsN)r ArgsForJobRefs)parsers "lib/surface/dataflow/jobs/drain.pyArgs Drain.Args)sV3/c [R"U5Hyn[RR UR UR URS9 [RRSRUR 55 M{ g![Racn[RRSRUR URRUR55 SnAMSnAff=f)zThis is what gets called when the user runs this command. Args: args: all the arguments that were provided to this command invocation. ) project_id region_idzStarted draining job [{0}]zFailed to drain 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 ExtractJobRefsrJobsr jobId projectIdlocationr statusPrintformatr HttpExceptionpayloadstatus_message)selfargsjob_referrors rRun Drain.Run.s ++D1   MM((&&  ( 5<r?sw ''02(9#D%%**D,=,=,@,@A$ DLL$ B$ r