o $i! @sUddlmZddlmZmZmZddlmZdZdZ ddddd Z ee eee ge ffe d <d aiZee ee fe d <Gd dde eZd S))Enum)CallableDictList)RAY_METRIC_CARDINALITY_LEVELWorkerIdNamecCt|SNsumvaluesrf/home/ubuntu/veenaModal/venv/lib/python3.10/site-packages/ray/_private/telemetry/metric_cardinality.py rcCr r r r rrrr rtasksactors'HIGH_CARDINALITY_METRICS_TO_AGGREGATIONN_HIGH_CARDINALITY_LABELSc@s~eZdZdZdZdZdZedddZede de e e ge ffd d Z ede e fd d Zede de e fd dZdS)MetricCardinalityaCardinality level configuration for all Ray metrics (ray_tasks, ray_actors, etc.). This configurtion is used to determine whether to globally drop high cardinality labels. This is important for high scale clusters that might consist thousands of workers, millions of tasks. - LEGACY: Keep all labels. This is the default behavior. - RECOMMENDED: Drop high cardinality labels. The set of high cardinality labels are determined internally by Ray and not exposed to users. Currently, this includes the following labels: WorkerId - LOW: Same as RECOMMENDED, but also drop the Name label for tasks and actors. legacy recommendedlowreturncCs:tdurtSz ttaWtStytjaYtSwr )_CARDINALITY_LEVELrrlower ValueErrorLEGACYrrrrget_cardinality_level$s z'MetricCardinality.get_cardinality_level metric_namecCs|tvrt|SddS)NcSs|dS)Nrrr rrrr3rz.)r)r"rrrget_aggregation_function/sz*MetricCardinality.get_aggregation_functioncCs ttSr )listrkeysrrrrget_high_cardinality_metrics5s z.MetricCardinality.get_high_cardinality_metricscCsl|tvrt|St}|tjks|tvrgt|<gStgt|<|tjkr2|dvr2t|tt|S)z@ Get the high cardinality labels of the metric. r) rrr!r r&WORKER_ID_TAG_KEYLOWappendTASK_OR_ACTOR_NAME_TAG_KEY)r"cardinality_levelrrr#get_high_cardinality_labels_to_drop9s   z5MetricCardinality.get_high_cardinality_labels_to_dropN)rr)__name__ __module__ __qualname____doc__r RECOMMENDEDr( staticmethodr!strrrfloatr#r&r,rrrrrs   "r)enumrtypingrrrray._private.ray_constantsrr'r*rr3r4__annotations__rrrrrrrs $