Skip to content

Commit 290911e

Browse files
adjust some help labels that were piggybacking on legacy for canonical
1 parent 08e1725 commit 290911e

2 files changed

Lines changed: 5 additions & 3 deletions

File tree

src/conductor/client/telemetry/canonical_metrics_collector.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -170,7 +170,7 @@ def set_active_workers(self, task_type: str, count: int) -> None:
170170
def record_task_poll_time(self, task_type: str, time_spent: float, status: str = "SUCCESS") -> None:
171171
self._observe_histogram(
172172
name=MetricName.TASK_POLL_TIME_HISTOGRAM,
173-
documentation=MetricDocumentation.TASK_POLL_TIME_HISTOGRAM,
173+
documentation=MetricDocumentation.TASK_POLL_TIME_HISTOGRAM_CANONICAL,
174174
labels={MetricLabel.TASK_TYPE: task_type, MetricLabel.STATUS: status},
175175
value=time_spent,
176176
buckets=TIME_BUCKETS,
@@ -179,7 +179,7 @@ def record_task_poll_time(self, task_type: str, time_spent: float, status: str =
179179
def record_task_execute_time(self, task_type: str, time_spent: float, status: str = "SUCCESS") -> None:
180180
self._observe_histogram(
181181
name=MetricName.TASK_EXECUTE_TIME_HISTOGRAM,
182-
documentation=MetricDocumentation.TASK_EXECUTE_TIME_HISTOGRAM,
182+
documentation=MetricDocumentation.TASK_EXECUTE_TIME_HISTOGRAM_CANONICAL,
183183
labels={MetricLabel.TASK_TYPE: task_type, MetricLabel.STATUS: status},
184184
value=time_spent,
185185
buckets=TIME_BUCKETS,

src/conductor/client/telemetry/model/metric_documentation.py

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -17,14 +17,16 @@ class MetricDocumentation(str, Enum):
1717
TASK_POLL_TIME_HISTOGRAM = "Task poll duration in seconds with quantiles"
1818
TASK_RESULT_SIZE = "Records output payload size of a task"
1919
TASK_UPDATE_ERROR = "Task status cannot be updated back to server"
20-
TASK_UPDATE_TIME_HISTOGRAM = "Task update duration in seconds with quantiles"
20+
TASK_UPDATE_TIME_HISTOGRAM = "Latency of task result updates in seconds"
2121
THREAD_UNCAUGHT_EXCEPTION = "thread_uncaught_exceptions"
2222
WORKER_RESTART = "Worker subprocess restarted"
2323
WORKFLOW_START_ERROR = "Counter for workflow start errors"
2424
WORKFLOW_INPUT_SIZE = "Records input payload size of a workflow"
2525

2626
# Canonical-only documentation strings
2727
API_REQUEST_TIME_CANONICAL = "Latency of HTTP API client requests in seconds"
28+
TASK_POLL_TIME_HISTOGRAM_CANONICAL = "Latency of task poll requests in seconds"
29+
TASK_EXECUTE_TIME_HISTOGRAM_CANONICAL = "Duration of worker task execution in seconds"
2830
TASK_EXECUTION_STARTED = "Incremented when a polled task is dispatched to the worker function"
2931
TASK_POLL_ERROR = "Incremented when a poll request fails client-side"
3032
TASK_RESULT_SIZE_BYTES = "Serialized byte size of task result output"

0 commit comments

Comments
 (0)