dZddlmZddlmZddlmZddlmZddlmZddl m Z ddl m Z dd l mZe je j j"e j$Gd d e j&Zy ) zGImplementation of gcloud dataflow jobs resume-unsupported-sdk command. )absolute_import)division)unicode_literals)apis) exceptions)base) job_utils)logc&eZdZdZedZdZy)Resumez~Resumes job running with the specified job id. Resumes a pipeline job which is running on an unsupported SDK version. cVtj||jdddy)z Register flags for this command.z--tokenz#The resume token unique to the job.T)helprequiredN)r ArgsForJobRef add_argument)parsers 3lib/surface/dataflow/jobs/resume_unsupported_sdk.pyArgsz Resume.Args&s.F# 3c Btj|} tjj |j d|j z|j|jtjjdj|j y#tj$rm}tjjdj|j |jj |j|j Yd}~yd}~wwxYw)zThis is what gets called when the user runs this command. Args: args: all the arguments that were provided to this command invocation. z)unsupported_sdk_temporary_override_token=) project_id region_idzResuming job running on unsupported SDK version [{0}]. This job may be cancelled in the future. For more details, see https://cloud.google.com/dataflow/docs/support/sdk-version-support-status.zFailed to resume job [{0}]: {1} Ensure that you have permission to access the job, the `--region` flag, {2}, is correct for the job and the `--token` flag, {3}, corresponds to the job.N)r ExtractJobRefrJobsResumeUnsupportedSDKjobIdtoken projectIdlocationr statusPrintformatr HttpExceptionpayloadstatus_message)selfargsjob_referrors rRunz Resume.Run0s %%d+G ii$$ -- 5 B&&$$ %&  jj=>DV"==>*+  # #  jjI Fmmmm**jj    sBBD1A#DDN)__name__ __module__ __qualname____doc__ staticmethodrr*rrr r s  rr N)r. __future__rrrgooglecloudsdk.api_lib.dataflowrgooglecloudsdk.api_lib.utilrgooglecloudsdk.callioper#googlecloudsdk.command_lib.dataflowr googlecloudsdk.corer ReleaseTracks ReleaseTrackALPHADefaultUniverseOnlyCommandr r0rrr<sj ''02(9#D%%++,.T\\.-.r