DSrSSKJr SSKJr SSKJr SSKrSSKJr SSKJr SSK J r SS K J r SS K J r SS K Jr SS KJr "S S\ R"5rg)z8Implementation of gcloud dataflow metrics list command. )absolute_import)division)unicode_literalsN)apis) exceptions) arg_parsers)base) dataflow_util) job_utils)timescZ\rSrSrSrSrSr\S5rSr Sr Sr S r S r S rS rS rg)List!aRetrieves the metrics from a specific job. This command can be used to explore the job's metrics at a fine-grained level. ## EXAMPLES Filter metrics with the given name: $ {command} JOB --filter="name=ElementCount" Filter child metrics with matching transforms: $ {command} JOB --transform=WordCount Filter child output metrics: $ {command} JOB --transform=WordCount/Write.*out Filter all output metrics: $ {command} JOB --transform=.*out Filter all custom-defined user metrics $ {command} JOB --source=user Filter metrics with a scalar value greater than a threshold. $ {command} JOB --filter="scalar > 50" List metrics that have changed in the last 2 weeks: $ {command} JOB --changed-after=-P2W userservicec[R"U5 [RR U5 [R R U5 [R R U5 URS[RRSS9 URSSSSS9 URS S S 9 URS S SSS.SSS9 URSSSSS9 g)z Register flags for this command.z--changed-afterzOnly display metrics that have changed 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--hide-committedF store_truezIf true, hide committed values.)defaultactionrz --transformz;Filters only the metrics that prefix match the given regex.)rz--sourcezRetrieves all metrics.z(Retrieves only dataflow service metrics.z#Retrieves only custom user metrics.)allrrrzSet the metrics source.)choicesrrz --tentativez"If true, display tentative values.N) r ArgsForJobRefr PAGE_SIZE_FLAGRemoveFromParser SORT_BY_FLAGURI_FLAG add_argumentrDatetimeParse)parsers $lib/surface/dataflow/metrics/list.pyArgs List.ArgsHsF#((0&&v.MM""6*   ! ! ' '')  . 0   JL +A9  &(  1 3c ^^[R"T5nTR=(a [R"TR5n/nTR (d'TR (a[R"S5eTR (d'TR (dURU4Sj5 O7TR (a&TR (aURU4Sj5 URUU4Sj5 URUU4Sj5 TR(aURU4Sj5 [RRURURURUS9nUR VVs/sH<n[#UVs/sH ow"U5PM sn5(dM+TR%U5PM> snn$s snfs snnf)a This is what gets called when the user runs this command. Args: args: all the arguments that were provided to this command invocation. Returns: List of metric values. Raises: exceptions.InvalidExclusionException: If the excluded metrics are not valid. z4Cannot exclude both tentative and committed metrics.c.>TRUS5S:g$N tentativetrue_GetContextValuemselfs r#List.Run..T221kBfLr&c.>TRUS5S:H$r)r,r.s r#r1r2r3r&c<>TRUTR5$N)_FilterBySourcesourcer/argsr0s r#r1r2s4//4;;?r&c<>TRUTR5$r6)_FilterByTransform transformr9s r#r1r2s4221dnnEr&c^>[R"UR5TR:$r6)r ParseDateTime updateTime changed_after)r/r:s r#r1r2sE'' 58J8JJr&) project_id region_id start_time)r ExtractJobRefrAr FormatDateTimer*hide_committedrInvalidExclusionExceptionappendrMetricsGetjobId projectIdlocationmetricsr_Format)r0r:job_refrDpredsresponser/preds`` r#RunList.RunosY%%d+G##P(<(>d11  0 0 @ BB ^^D$7$7 llLM D// llLM LL?@ LLEF  ll JL|| $$""  H &.%5%5 1%5.DG./ DLLO%5 11. 1sG #G4 G G G cX[RRURR5(dg[R RURR5(dgUR RS:H=(d UR RS:H$)zThis returns true if the metric is a watermark with a sentinel value. Args: metric: A single UpdateMetric returned from the API. Returns: True if the metric is a sentinel value, false otherwise. F)r DATAFLOW_METRICS_REmatchnameoriginWINDMILL_WATERMARK_REscalar integer_valuer0metrics r#_IsSentinelWatermarkList._IsSentinelWatermarksz  , , 2 26;;3E3E F F   . . 4 4V[[5E5E F F  MM ' '2 - . MM ' '2 -/r&c>URRnUS:Xagg)azThis method gets the description of the watermark sentinel value. There are only two watermark sentinel values we care about, -1 represents a watermark at kInt64Min. -2 represents a watermark at kInt64Max. This runs on the assumption that _IsSentinelWatermark was called first. Args: metric: A single UpdateMetric returned from the API. Returns: The sentinel description. rXzUnknown watermarkz Max watermark)r_r`)r0rbvalues r# _GetWatermarkSentinelDescription%List._GetWatermarkSentinelDescriptions  MM ' 'E { r&cURU5(a;URU5URlURR S5 U$)zPerforms extra formatting for sentinel values or otherwise. Args: metric: A single UpdateMetric returned from the API. Returns: The formatted metric. r`)rcrgr_ string_valueresetras r#rP List._FormatsC   ((#'#H#H#Pfmm  mm/* Mr&cURUS5=(d SnURUS5=(d Sn[R"U=(d S5nURU5(dURU5(agg)Noutput_user_namestepTF)r-recompiler[)r0rbr=rnrps r#r<List._FilterByTransformsh,,V5GHNB   0 6BD 9?+I'((IOOD,A,A  r&cX R:XaURRS:H$X R:XaURRS:H$g)Nrz dataflow/v1b3T) USER_SOURCEr\r]SERVICE_SOURCE)r0rbr8s r#r7List._FilterBySourcesG !!! [[  6 )) && & [[  ? 22 r&cURR(aEURRRH!nURU:XdMURs $ gr6)r\contextadditionalPropertieskeyrf)r0rbr{props r#r-List._GetContextValuesC {{++%%::$ 88s? ; r&N)__name__ __module__ __qualname____firstlineno____doc__rurv staticmethodr$rUrcrgrPr<r7r-__static_attributes__r~r&r#rr!sK!F+.$3$3L(1T/$" r&r)r __future__rrrrqgooglecloudsdk.api_lib.dataflowrrgooglecloudsdk.callioperr #googlecloudsdk.command_lib.dataflowr r googlecloudsdk.core.utilr ListCommandrr~r&r#rsA'' 06/(=9*|4  |r&