SrSSKJr SSKJr SSKJr SSKJr SSKJr SSKJ r SSK J r SS K J r SS K Jr "S S \ R5rg )z5Implementation of gcloud dataflow logs list command. )absolute_import)division)unicode_literals)apis) arg_parsers)base) dataflow_util) job_utils)timesc.\rSrSrSr\S5rSrSrg)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 cr[R"U5 [RR U5 [R R U5 [R R U5 [RR U5 URS[RRSS9 URS[RRSS9 URS/SQSS S 9 URRS 5 S S SSSS.0nURRU5 g)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.pyArgs List.Args:s$ F#&&v.MM""6*OO$$V,((0   ! ! ' '')   ! ! ' 'NP  9 F H  !!# + # " -G %%g.c [R"U5n[RRR nUR URURURS.n[RR URURURUR=(a XARUR=(a [R "UR5UR"=(a [R "UR"5S9n[$R&"URURUR[RR)5UUR*SSS9$)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 MinimumImportanceValueValuesEnumrrrrr3r4r5 importanceafterr FormatDateTimebeforer YieldFromList GetServicelimit)selfargsjob_refimportance_enumimportance_mapr?s r.RunList.Rungs)%%d+G ""CC!22#88 22"66 Nmm((##mm!!??N~oo/N**A!5!5djj!A A 4 4T[[ A) CG  & &}}$$"" ((*::' r1N) __name__ __module__ __qualname____firstlineno____doc__ staticmethodr/rS__static_attributes__rUr1r.r r s!6*/*/X'r1r N)rZ __future__rrrgooglecloudsdk.api_lib.dataflowrgooglecloudsdk.callioperr#googlecloudsdk.command_lib.dataflowr r googlecloudsdk.core.utilr ListCommandr rUr1r.rcs;''0/(=9*p4  pr1