&`i0tddlZddlZddlZddlmZmZmZmZmZm Z ddl m Z ddl m ZmZmZmZddlmZejeZejdZdedefd ZeGd d ZeGd d eZ eGddeZeGddeZgdZ!dS)N)AnyDictListOptionalTupleUnion)env_bool)CountGauge HistogramSum) DeveloperAPIz^[a-zA-Z_:][a-zA-Z0-9_:]*$namereturnct|dkrtdt|s t jd|dt dSdS)Nrz8Empty name is not allowed. Please provide a metric name.zInvalid metric name: z. Metric will be discarded and data will not be collected or published. Metric names can only contain letters, numbers, _, and :. Metric names cannot start with numbers.TF)len ValueError_VALID_METRIC_NAME_REmatchwarningswarn UserWarning)rs d/home/jaya/work/projects/VOICE-AGENT/VIET/agent-env/lib/python3.11/site-packages/ray/util/metrics.py_is_invalid_metric_namersq 4yyA~~STTT & &t , ,  6D 6 6 6     t 5c eZdZdZ ddededeeedffdZd eeeffd Z dd e e e fd eeeefd dfdZ dZdZed eeeffdZdS)MetriczThe parent class of custom metrics. Ray's custom metrics APIs are rooted from this class and share the same public methods. Nr descriptiontag_keys.ct||_||_||_i|_|p t |_d|_t|jt s$tdt|j|jD]7}t|ts tdt|d8d|jvr%tj d|jdtdSdS)Nz&tag_keys should be a tuple type, got: zTag keys must be str, got .:z Metric name z contains a : character, which is no longer allowed. Please migrate to the new metric name format. This will be an error in the future.)r_discard_metric_name _description _default_tagstuple _tag_keys_metric isinstance TypeErrortypestrrr FutureWarning)selfrrr keys r__init__zMetric.__init__1s 7t<< '!,UWW $.%00 RD K KCc3'' K IT#YY I I IJJJ K $*   M8tz888        r default_tagsc|D]V\}}||jvrtd|dt|ts t dt |dW||_|S)aSet default tags of metrics. Example: >>> from ray.util.metrics import Counter >>> # Note that set_default_tags returns the instance itself. >>> counter = Counter("name", tag_keys=("a",)) >>> counter2 = counter.set_default_tags({"a": "b"}) >>> assert counter is counter2 >>> # this means you can instantiate it in this way. >>> counter = Counter("name", tag_keys=("a",)).set_default_tags({"a": "b"}) Args: default_tags: Default tags that are used for every record method. Returns: Metric: it returns the instance itself. zUnrecognized tag key r"Tag values must be str, got )itemsr)rr+r.r,r-r')r0r3r1vals rset_default_tagszMetric.set_default_tagsTs&%**,, M MHC$.(( !?!?!?!?@@@c3'' M KtCyy K K KLLL M* rvaluetagsrc|jrdS|jJ||}|||j||dS)zRecord the metric point of the metric. Tags passed in will take precedence over the metric's default tags. Args: value: The value to be recorded as a metric point. Nr:)r$r*_get_final_tags_validate_tagsrecord)r0r9r: final_tagss r_recordzMetric._recordpsj    F|'''))$//  J''' E 33333rc|s|jS|D]7}t|ts t dt |d8i|j|S)Nr5r")r'valuesr+r.r,r-)r0r:r7s rr=zMetric._get_final_tagssz &% %;;== M MCc3'' M KtCyy K K KLLL M.$$---rcg}|jD]}||vr|||r&tdd|ddS)NzMissing value for tag key(s): ,r")r)appendrjoin)r0r@ missing_tagstag_keys rr>zMetric._validate_tagssu ~ - -Gj((##G,,,  YWchh|>T>TWWWXX X Y Yrc8|j|j|j|jdS)a0Return the information of this metric. Example: >>> from ray.util.metrics import Counter >>> counter = Counter("name", description="desc") >>> print(counter.info) {'name': 'name', 'description': 'desc', 'tag_keys': (), 'default_tags': {}} )rrr r3)r%r&r)r')r0s rinfoz Metric.infos)J, .    rrNN)__name__ __module__ __qualname____doc__r.rrr2rr8rintfloatrAr=r>propertyrrKrrrr)s,.2 !!!!5c?+ !!!!FT#s(^>*.44S%Z 4tCH~&4  4444*... Y Y Y d38n   X   rrc eZdZdZ ddededeeedfffd Zd Zdd e e e fd e eeffd Z xZS)CounteracA cumulative metric that is monotonically increasing. This corresponds to Prometheus' counter metric: https://prometheus.io/docs/concepts/metric_types/#counter Before Ray 2.10, this exports a Prometheus gauge metric instead of a counter metric, which is wrong. Since 2.10, this exports both counter (with a suffix "_total") and gauge metrics (for bug compatibility). Use `RAY_EXPORT_COUNTER_AS_GAUGE=0` to disable exporting the gauge metric. Args: name: Name of the metric. description: Description of the metric. tag_keys: Tag keys of the metric. rNrrr .c*t||||jr d|_dSt ddr( t |j|j|j|_dS t|j|j|j|_dS)NRAY_enable_open_telemetryT) superr2r$r*r CythonCountr%r&r) CythonSumr0rrr __class__s rr2zCounter.__init__s {H555   XDLLL3T:: X +J 14>    )T5FWW rc@|j}|j|j|jf}||fSrM)r^r%r&r)r0 deserializerserialized_datas r __reduce__zCounter.__reduce__s'~ :t'8$.I_,,r?r9r:ct|ttfs tdt |d|dkrt d||||dS)a0Increment the counter by `value` (defaults to 1). Tags passed in will take precedence over the metric's default tags. Args: value(int, float): Value to increment the counter by (default=1). tags(Dict[str, str]): Tags to set or override for this counter. value must be int or float, got r"rzvalue must be >0, got r<N)r+rRrSr,r-rrAr0r9r:s rincz Counter.incsw%#u.. OMtE{{MMMNN N A::=e==>> > U &&&&&rrL)rdN)rNrOrPrQr.rrr2rcrrRrSrrh __classcell__r^s@rrWrWs(.2 XXXX5c?+ XXXXXX4--- ''sEz*'S#X''''''''rrWc eZdZdZ ddededeedeeedfffd Z dd e e efd e eeffd Z d ZefdZxZS)r aTracks the size and number of events in buckets. Histograms allow you to calculate aggregate quantiles such as 25, 50, 95, 99 percentile latency for an RPC. This corresponds to Prometheus' histogram metric: https://prometheus.io/docs/concepts/metric_types/#histogram Args: name: Name of the metric. description: Description of the metric. boundaries: Boundaries of histogram buckets. tag_keys: Tag keys of the metric. rNrr boundariesr .c|t||||t|dkrtdt |D]!\}}|dkrtd|d|d"||_|jr d|_dSt|j |j |j|j |_dS)Nrzuboundaries argument should be provided when using the Histogram class. e.g., Histogram("name", boundaries=[1.0, 2.0])z'Invalid `boundaries` argument at index z, z(. Use positive values for the arguments.) rZr2rr enumeraterlr$r*CythonHistogramr%r&r))r0rrrlr iboundaryr^s rr2zHistogram.__init__s {H555  ZA!5!5;  %Z00  KAx1}} QQQ&QQQ %   DLLL* D-tDLLLrr9r:ct|ttfs tdt |d|||dS)a&Observe a given `value` and add it to the appropriate bucket. Tags passed in will take precedence over the metric's default tags. Args: value(int, float): Value to set the gauge to. tags(Dict[str, str]): Tags to set or override for this gauge. rfr"Nr+rRrSr,r-rArgs robservezHistogram.observesU%#u.. OMtE{{MMMNN N UD!!!!!rcLt}|j|j|j|jf}||fSrM)r r%r&rlr)r`s rrczHistogram.__reduce__+s0 J   O N   _,,rcftj}|d|ji|S)z*Return information about histogram metric.rl)rZrKupdaterl)r0rKr^s rrKzHistogram.info5s.ww| \4?3444 r)rNNrM)rNrOrPrQr.rrSrrr2rrRrrtrcrTrKrirjs@rr r s  $"&.2 K  5c?+ : " "U3:. "d38n " " " "---Xrr c eZdZdZ d dededeeedfffd Zdd eee e fd e eeffd Z d Z xZS)r atGauges keep the last recorded value and drop everything before. Unlike counters, gauges can go up or down over time. This corresponds to Prometheus' gauge metric: https://prometheus.io/docs/concepts/metric_types/#gauge Args: name: Name of the metric. description: Description of the metric. tag_keys: Tag keys of the metric. rNrrr .ct||||jr d|_dSt |j|j|j|_dSrM)rZr2r$r* CythonGauger%r&r)r]s rr2zGauge.__init__LsV {H555   VDLLL&tz43DdnUUDLLLrr9r:c|dSt|ttfs tdt |d|||dS)a?Set the gauge to the given `value`. Tags passed in will take precedence over the metric's default tags. Args: value(int, float): Value to set the gauge to. If `None`, this method is a no-op. tags(Dict[str, str]): Tags to set or override for this gauge. Nrfr"rsrgs rsetz Gauge.setXs_ = F%#u.. OMtE{{MMMNN N UD!!!!!rc@t}|j|j|jf}||fSrM)r r%r&r)r`s rrczGauge.__reduce__js% :t'8$.I_,,rrLrM)rNrOrPrQr.rrr2rrRrSrr|rcrirjs@rr r =s   .2 V V V V5c?+ V V V V V V""%U "34"DcN""""$-------rr )rWr r )"loggingrertypingrrrrrrray._private.ray_constantsr ray._rayletr r[r rzr ror r\ray.util.annotationsr getLoggerrNloggercompilerr.boolrrrW__all__rUrrrs :::::::::::::::://////.-----  8 $ $ # #@AA # $            D?'?'?'?'?'f?'?'?'DJJJJJJJJZ/-/-/-/-/-F/-/-/-d   r