Coverage for qreward / utils / scheduler / metrics.py: 100.00%

1"""Execution metrics for schedule decorator.""" 

2 

3from dataclasses import dataclass (empty)

4from typing import Any, Optional (empty)

5 

6 

7@dataclass (empty)

8class ScheduleMetrics: (empty)

9 """Execution metrics collected after a schedule invocation. 

10 

11 Attributes: 

12 total_calls: Total number of task submissions (including retries 

13 and hedged requests). 

14 success_count: Number of successful completions. 

15 failure_count: Number of failed attempts. 

16 retry_count: Number of retries (excludes the first attempt). 

17 total_latency_ms: Wall-clock latency from start to finish 

18 in milliseconds. 

19 avg_latency_ms: Average latency per attempt in milliseconds. 

20 """ 

21 

22 total_calls: int (empty)

23 success_count: int (empty)

24 failure_count: int (empty)

25 retry_count: int (empty)

26 total_latency_ms: float (empty)

27 avg_latency_ms: float (empty)

28 

29 def export_to_otel(self, exporter: Optional[Any] = None) -> None: (empty)

30 """Export metrics to OpenTelemetry via a TelemetryExporter. 

31 

32 Args: 

33 exporter: A TelemetryExporter instance. If None, this is a no-op. 

34 """ 

35 if exporter is not None: (empty)

36 exporter.record(self) (empty)