dZddlmZddlmZddlmZddlmZddlmZddlm Z ddl m Z dd l m Z dd l mZGd d e jZy )z5Implementation of gcloud dataflow logs list command. )absolute_import)division)unicode_literals)apis) arg_parsers)base) dataflow_util) job_utils)timesc&eZdZdZedZdZy)ListaRetrieve the job logs for a specific job. Retrieves the job logs from a specified job using the Dataflow Messages API with at least the specified importance level. Can also be used to display logs between a given time period using the --before and --after flags. These logs are produced by the service and are distinct from worker logs. Worker logs can be found in Cloud Logging. ## EXAMPLES Retrieve only error logs: $ {command} --importance=error Retrieve all logs after some date: $ {command} --after="2016-08-12 00:00:00" Retrieve logs from this year: $ {command} --after=2018-01-01 Retrieve logs more than a week old: $ {command} --before=-P1W ctj|tjj |tj j |tj j |tjj ||jdtjjd|jdtjjd|jdgddd |jjd d d ddddi}|jj|y)Nz--afterzOnly display messages logged after the given time. See $ gcloud topic datetimes for information on time formats. For example, `2018-01-01` is the first day of the year, and `-P2W` is 2 weeks ago.)typehelpz--beforezqOnly display messages logged before the given time. See $ gcloud topic datetimes for information on time formats.z --importance)debugdetailedwarningerrorrz7Minimum importance a message must have to be displayed.)choicesdefaultrz table[no-heading,pad=1]( messageImportance.enum(dataflow.JobMessage), time.date(tz=LOCAL):label=TIME, id, messageText:label=TEXT ) zdataflow.JobMessage::enumdDWE)JOB_MESSAGE_DETAILEDJOB_MESSAGE_DEBUGJOB_MESSAGE_WARNINGJOB_MESSAGE_ERROR)r ArgsForJobRefr SORT_BY_FLAGRemoveFromParserURI_FLAG ASYNC_FLAGPAGE_SIZE_FLAG add_argumentrDatetimeParse display_info AddFormat AddTransforms)parsersymbolss !lib/surface/dataflow/logs/list.pyArgsz List.Args:s$ F#&&v.MM""6*OO$$V,((0   ! ! ' '')   ! ! ' 'NP  9 F H  !!# + # " -G %%g.c tj|}tjjj }|j |j|j|jd}tjj |j|j|j|jxr||j|jxrtj |j|j"xrtj |j"}t%j&|j|j|jtjj)||j*ddS)zThis is what gets called when the user runs this command. Args: args: all the arguments that were provided to this command invocation. Returns: None on success, or a string containing the error message. )rrrr) projectIdjobIdlocationminimumImportance startTimeendTimepageSize jobMessages)job_id project_id region_idservicerequest batch_sizebatch_size_attributefield)r ExtractJobRefrMessages LIST_REQUEST MinimumImportanceValueValuesEnumrrrrr1r2r3 importanceafterr FormatDateTimebeforer YieldFromList GetServicelimit)selfargsjob_refimportance_enumimportance_mapr=s r-RunzList.Rungs+%%d+G ""CC!22#88 22"66 Nmm((##mm!!??N~doo/N**A!5!5djj!A A 4 4T[[ A) CG  & &}}$$"" ((*::' r/N)__name__ __module__ __qualname____doc__ staticmethodr.rQr/r-r r s!6*/*/X'r/r N)rU __future__rrrgooglecloudsdk.api_lib.dataflowrgooglecloudsdk.callioperr#googlecloudsdk.command_lib.dataflowr r googlecloudsdk.core.utilr ListCommandr rWr/r-r^s;''0/(=9*p4  pr/