R dZddlmZddlmZddlmZddlmZddlmZddl m Z ejejjejjGdd ejZy ) z9Implementation of gcloud dataflow jobs describe command. )absolute_import)division)unicode_literals)apis)base) job_utilsc&eZdZdZedZdZy)DescribeaOutputs the Job object resulting from the Get API. By default this will display the Summary view which includes: - Project ID - Regional Endpoint - Job ID - Job Name - Job Type (Batch vs. Streaming) - Job Create Time - Job Status (Running, Done, Cancelled, Failed) - Job Status Time Notable values that are only in the full view: - Environment (staging Jars, information about workers, etc.) - Steps from the workflow graph c tj||jddtjj j jtjj j jdy)zrRegister flags for this command. Args: parser: argparse.ArgumentParser to register arguments with. z--full store_constz2Retrieve the full Job rather than the summary view)actionconstdefaulthelpN) r ArgsForJobRef add_argumentrJobs GET_REQUESTViewValueValuesEnum JOB_VIEW_ALLJOB_VIEW_SUMMARY)parsers %lib/surface/dataflow/jobs/describe.pyArgsz Describe.Args/saF# ii##77DD %%99JJ A Cctj|}tjj |j |j |j|jS)zRuns the command. Args: args: The arguments that were provided to this command invocation. Returns: A Job message. ) project_id region_idview) r ExtractJobRefrrGetjobId projectIdlocationfull)selfargsjob_refs rRunz Describe.Run?sN%%d+G 99== $$"" YY  rN)__name__ __module__ __qualname____doc__ staticmethodrr)rrr r s"" C Crr N)r- __future__rrrgooglecloudsdk.api_lib.dataflowrgooglecloudsdk.callioper#googlecloudsdk.command_lib.dataflowr ReleaseTracks ReleaseTrackBETAGADescribeCommandr r/rrr9sg ''0(9D%%**D,=,=,@,@A0t##0B0r