diff --git a/src/k1link/compute/pipeline_telemetry.py b/src/k1link/compute/pipeline_telemetry.py index ed1d848..40d0b0f 100644 --- a/src/k1link/compute/pipeline_telemetry.py +++ b/src/k1link/compute/pipeline_telemetry.py @@ -307,8 +307,11 @@ def build_pipeline_telemetry_document( if state not in STAGE_STATES: raise PipelineTelemetryError("stage telemetry state is invalid") duration_ms = _optional_duration(duration_ms, "duration_ms") - activation_count = _optional_count(activation_count, "activation_count") - if activation_count in {None, 0}: + validated_activation_count = _optional_count( + activation_count, + "activation_count", + ) + if validated_activation_count in {None, 0}: raise PipelineTelemetryError("activation_count must be positive") input_count = _optional_count(input_count, "input_count") output_count = _optional_count(output_count, "output_count") @@ -342,7 +345,7 @@ def build_pipeline_telemetry_document( "elapsed_seconds": ( round(duration_ms / 1000.0, 9) if duration_ms is not None else None ), - "activations": activation_count, + "activations": validated_activation_count, "input_count": input_count, "output_count": output_count, "queue_wait_ms": queue_wait_ms, @@ -351,7 +354,7 @@ def build_pipeline_telemetry_document( "stage_id": stage_id, "state": state, "duration_ms": duration_ms, - "activation_count": activation_count, + "activation_count": validated_activation_count, "input_count": input_count, "output_count": output_count, "queue_wait_ms": queue_wait_ms, diff --git a/src/k1link/viewer/rerun_bridge.py b/src/k1link/viewer/rerun_bridge.py index 7fcfb14..905bde4 100644 --- a/src/k1link/viewer/rerun_bridge.py +++ b/src/k1link/viewer/rerun_bridge.py @@ -43,7 +43,7 @@ DEFAULT_CORS_ORIGINS = ( "http://localhost:8000", ) -logger = logging.getLogger("k1link.device_plugins.xgrids_k1.viewer_receiver") +logger = logging.getLogger("k1link.viewer.rerun_bridge") @dataclass(frozen=True, slots=True) diff --git a/tests/test_rerun_bridge.py b/tests/test_rerun_bridge.py index 9ca52d2..41946f7 100644 --- a/tests/test_rerun_bridge.py +++ b/tests/test_rerun_bridge.py @@ -77,7 +77,7 @@ def test_rerun_port_selection_skips_a_recording_still_held_by_a_viewer( recording = FakeRecording() with caplog.at_level( logging.INFO, - logger="k1link.device_plugins.xgrids_k1.viewer_receiver", + logger="k1link.viewer.rerun_bridge", ): bridge = RerunBridge( grpc_port=preferred_port,