p TSrSSKJr SSKJr SSKJr SSKJr SSKJr SSKJ r SSKJ r SS K J r SS K Jr SS K Jr SS KJr SS KJr \ R("\ R*R,\ R*R.5"SS\ R055r"SS\5rg)z4Implementation of gcloud dataflow jobs list command.)absolute_import)division)unicode_literals)apis) job_display) arg_parsers)base) dataflow_util)log) properties)resource_filter)timesc>\rSrSrSr\S5rSrSrS Sjr Sr g) List aYLists all jobs in a particular project, optionally filtered by region. By default, 100 jobs in the current project are listed; this can be overridden with the gcloud --project flag, and the --limit flag. Using the --region flag will only list jobs from the given regional endpoint. ## EXAMPLES Filter jobs with the given name: $ {command} --filter="name=my-wordcount" List jobs with from a given region: $ {command} --region="europe-west1" List jobs created this year: $ {command} --created-after=2018-01-01 List jobs created more than a week ago: $ {command} --created-before=-P1W c:[RRU5 [RR US5 [R R US5 UR SSSSS.SS 9 UR S [RRS S 9 UR S [RRSS 9 UR SSSS9 URRS5 URR[R5 g)z Register flags for this command.dz--statuszReturns running jobs first, ordered on creation timestamp, then, returns all terminated jobs ordered on the termination timestamp.zFilters the jobs that have a terminated state, ordered on the termination timestamp. Example terminated states: Done, Updated, Cancelled, etc.zDFilters the jobs that are running ordered on the creation timestamp.all terminatedactivez2Filter the jobs to those with the selected status.)choiceshelpz--created-afterzFilter the jobs to those created 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.)typerz--created-beforezuFilter the jobs to those created before the given time. See $ gcloud topic datetimes for information on time formats.z--regionREGIONzOnly resources from the given region are queried. If not provided, an attempt will be made to query from all available regions. In the event of an outage, jobs from certain regions may not be available.)metavarrz table( id:label=JOB_ID, name:label=NAME, type:label=TYPE, creationTime.yesno(no="-"), state, location:label=REGION ) N)r ASYNC_FLAGRemoveFromParser LIMIT_FLAG SetDefaultPAGE_SIZE_FLAG add_argumentrDatetimeParse display_info AddFormat AddUriFuncr JobsUriFunc)parsers !lib/surface/dataflow/jobs/list.pyArgs List.Args<s$ OO$$V,OOvs+""62. ,  BC    ! ! ' '')   ! ! ' 'NP   , . !! #   ""=#<#<=cr^^TR(a*[R"TR5mUU4SjnUnO [T5n[R R RRSS9nURUTU5nUVs/sHn[R"U5PM sn$s snf)zRuns the command. Args: args: All the arguments that were provided to this command invocation. Returns: An iterator over Job messages. c~>TR[R"U55=(a [T5"U5$N)Evaluater DisplayInfo _JobFilter)xargs filter_exprs r+ EvalFilterList.Run..EvalFilters3$$[%<%>'" $ $r.Nc8SnU(a*[R"5RRnO)[R"5RRnUR UR URS.nURXR 5$)zReturn a string describing the job status. Args: status: The job status enum region: The region argument, to select the correct wrapper message. Returns: string describing the job status Nr) rGetMessagesModule(DataflowProjectsLocationsJobsListRequestFilterValueValuesEnum%DataflowProjectsJobsAggregatedRequestALL TERMINATEDACTIVEget)rBrVrWfilter_value_enum value_maps r+rUList._StatusArgToFilters  " K K   " H H  !$$'22#**I ==!6!6 77r.r1) __name__ __module__ __qualname____firstlineno____doc__ staticmethodr,rGrArU__static_attributes__rpr.r+rr s,48>8>t:2$$L8r.rc*\rSrSrSrSrSrSrSrg)r4zPredicate for filtering jobs.c/UlUR(dUR(a'URURUR5 gg)zpCreate a _JobFilter from the given args. Args: args: The argparse.Namespace containing the parsed arguments. N)preds created_aftercreated_before_ParseTimePredicate)rBr6s r+__init___JobFilter.__init__s= DJ T00 t1143F3FG1r.cb[URVs/sH o""U5PM sn5$s snfr1)rr{)rBrFpreds r+__call___JobFilter.__call__s' djj1jdS j1 221s,c$^^T(a'T(d URRU4Sj5 gT(d'T(a URRU4Sj5 gT(a+T(a#UU4SjnURRU5 ggg)zReturn a predicate for filtering jobs by their creation time. Args: after: Only return true if the job was created after this time. before: Only return true if the job was created before this time. cJ>[R"UR5T:$r1r ParseDateTime createTime)r5afters r+0_JobFilter._ParseTimePredicate..s%"5"5all"Ce"Kr.cJ>[R"UR5T:*$r1r)r5befores r+rrs%"5"5all"Cv"Mr.cf>[R"UR5nTU:=(a UT:*$r1r)r5 create_timerrs r+ _Predicate2_JobFilter._ParseTimePredicate.._Predicates,))!,,7 {"<{f'<rs;&'07/(=#*8*D%%**D,=,=,@,@Ao84  o8Bo8d!$!$r.