From 015a0f9935bd3e061d046d57e6e5fbc64ec706c5 Mon Sep 17 00:00:00 2001 From: Edward Oakes Date: Mon, 21 Dec 2020 17:19:39 -0600 Subject: [PATCH] [serve] Rename replica_tag -> replica in metrics for consistency (#13022) --- python/ray/serve/backend_worker.py | 20 ++++++++++---------- 1 file changed, 10 insertions(+), 10 deletions(-) diff --git a/python/ray/serve/backend_worker.py b/python/ray/serve/backend_worker.py index 73088b558..1644c1690 100644 --- a/python/ray/serve/backend_worker.py +++ b/python/ray/serve/backend_worker.py @@ -186,10 +186,10 @@ class RayServeReplica: "backend_replica_starts", description=("The number of time this replica " "has been restarted due to failure."), - tag_keys=("backend", "replica_tag")) + tag_keys=("backend", "replica")) self.restart_counter.set_default_tags({ "backend": self.backend_tag, - "replica_tag": self.replica_tag + "replica": self.replica_tag }) self.queuing_latency_tracker = metrics.Histogram( @@ -198,39 +198,39 @@ class RayServeReplica: "The latency for queries waiting in the replica's queue " "waiting to be processed or batched."), boundaries=DEFAULT_LATENCY_BUCKET_MS, - tag_keys=("backend", "replica_tag")) + tag_keys=("backend", "replica")) self.queuing_latency_tracker.set_default_tags({ "backend": self.backend_tag, - "replica_tag": self.replica_tag + "replica": self.replica_tag }) self.processing_latency_tracker = metrics.Histogram( "backend_processing_latency_ms", description="The latency for queries to be processed", boundaries=DEFAULT_LATENCY_BUCKET_MS, - tag_keys=("backend", "replica_tag", "batch_size")) + tag_keys=("backend", "replica", "batch_size")) self.processing_latency_tracker.set_default_tags({ "backend": self.backend_tag, - "replica_tag": self.replica_tag + "replica": self.replica_tag }) self.num_queued_items = metrics.Gauge( "replica_queued_queries", description=("Current number of queries queued in the " "the backend replicas"), - tag_keys=("backend", "replica_tag")) + tag_keys=("backend", "replica")) self.num_queued_items.set_default_tags({ "backend": self.backend_tag, - "replica_tag": self.replica_tag + "replica": self.replica_tag }) self.num_processing_items = metrics.Gauge( "replica_processing_queries", description="Current number of queries being processed", - tag_keys=("backend", "replica_tag")) + tag_keys=("backend", "replica")) self.num_processing_items.set_default_tags({ "backend": self.backend_tag, - "replica_tag": self.replica_tag + "replica": self.replica_tag }) self.restart_counter.record(1)