fix(architecture): restore generic runtime boundaries

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,

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)

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,