[Th,%SSKrSSKrSSKJr SSKJr SSKJr SSKJ r /SQr \"S/SQ5r "S S 5r "S S \R5r"S S\5r"SS\5r"SS5r0r\\\4\S'\"5q\\S'S&S\S\\4SjjrS\4SjrSrS'S\4Sjjr\ "S\S9S&Sj5rS(S\S\S \4S!jjr\ "S"\S9S \S\S\4S#j5rS$\ 4S%jr!g))N) namedtuplewraps)Optional) deprecated) MetricsConfig MetricHandlerConsoleMetricHandlerNullMetricHandler MetricStream configure getStreamprofprofile put_metricpublish_metricget_elapsed_time_ms MetricDatar) timestamp group_namenamevaluec<\rSrSrS/rSS\\\\44SjjrSr g)r%paramsNc:XlURc0UlggNr)selfrs ]/var/www/auris/envauris/lib/python3.13/site-packages/torch/distributed/elastic/metrics/api.py__init__MetricsConfig.__init__(s ;; DK rr) __name__ __module__ __qualname____firstlineno__ __slots__rdictstrr!__static_attributes__r#r rr%s' IxS#X7r#rc@\rSrSr\R S\4Sj5rSrg)r . metric_datacgrr,rr/s r emitMetricHandler.emit/s r#r,N) r$r%r&r'abcabstractmethodrr2r+r,r#r r r .s!   r#r c"\rSrSrS\4SjrSrg)r 4r/c [SURSURSURSUR35 g)N[z][z]: =)printrrrrr1s r r2ConsoleMetricHandler.emit5sD  %%&b)?)?(@KDTDTCUUVWbWhWhVi j r#r,Nr$r%r&r'rr2r+r,r#r r r 4s  r#r c"\rSrSrS\4SjrSrg)r ;r/cgrr,r1s r r2NullMetricHandler.emit<s r#r,Nr=r,r#r r r ;s  r#r c8\rSrSrS\S\4SjrS\S\4SjrSr g ) r @rhandlercXlX lgrrrD)rrrDs r r!MetricStream.__init__As $ r# metric_name metric_valuecURR[[R"5URX55 gr)rDr2rtimer)rrHrIs r add_valueMetricStream.add_valueEs*  tyy{DOO[ O r#rFN) r$r%r&r'r*r r!intrLr+r,r#r r r @s(3 S  r#r _metrics_map_default_metrics_handlerrDgroupc"UcUqgU[U'gr)rPrO)rDrQs r r r Ps }$+ % Ur#cLU[;a [UnO[n[X5$r)rOrPr )rQrDs r rrZs$ u%*  ''r#cURnURS5n[U5S:Xa5URnU(aURS5SS-US-$US$U$)N.r)r&splitlenr%)fnqualnamerXmodules r _get_metric_namer]bs`H NN3 E 5zQ <<$R(3.q9 98Or#c2^U4SjnU(aU"U5$U$)a @profile decorator publishes duration.ms, count, success, failure metrics for the function that it decorates. The metric name defaults to the qualified name (``class_name.def_name``) of the function. If the function does not belong to a class, it uses the leaf module name instead. Usage :: @metrics.prof def x(): pass @metrics.prof(group="agent") def y(): pass c4>^[T5UU4Sj5nU$)Nc(>[T5n[R"5nT"U0UD6n[US3ST5 [US3[ U5T5 U$![a [US3ST5 ef=f![US3[ W5T5 f=fNz.successrVz.failurez .duration.ms)r]rKr Exceptionr)argskwargskeystartresultfrQs r wrapper#prof..wrap..wrappers"1%C T D+F+cU(+Q6 cU,/1DU1KUSM  cU(+Q6 cU,/1DU1KUSs-AA33A66Br)rhrirQs` r wrapprof..wraps q   r#r,)rZrQrks ` r rros*" Bx r#zDeprecated, use `@prof` instead)categoryc^U4SjnU$)z @profile decorator adds latency and success/failure metrics to any given function. Usage :: @metrics.profile("my_metric_group") def some_function(): c4>^[T5UU4Sj5nU$)Nc b>[R"5nT"U0UD6n[TTRS3S5 [TTRS3[ U55 U$![a [TTRS3S5 ef=f![TTRS3[ W55 f=fra)rKrr$rbr)rcrd start_timergfuncrQs r ri&profile..wrap..wrappers !YY[ t.v.ux&@!D }}o\2' 3 M ux&@!D }}o\2' 3s7A &BB %B.r)rrrirQs` r rkprofile..wraps t    r#r,)rQrks` r rrs( Kr#rHrI metric_groupc8[U5RX5 g)z{ Publish a metric data point. Usage :: put_metric("metric_name", 1) put_metric("metric_name", 1, "metric_group_name") NrrL)rHrIrus r rrsl%%k@r#zMDeprecated, use `put_metric(metric_group)(metric_name, metric_value)` insteadc<[U5nURX5 grrw)rurHrI metric_streams r rrs l+MK6r#start_time_in_secondscL[R"5n[X- S-5$)zrs@ "(   &R S  CGG  =     *, d3 %&+*;*=-=&}&Xc]&(S( ))X - F G F AC As A# A S 7737c7 7 :u:r#