From 093df8b38f636f287a2533e458a8d5fd7250926d Mon Sep 17 00:00:00 2001 From: DCCONSTRUCTIONS Date: Wed, 2 Sep 2026 20:43:31 +0300 Subject: [PATCH] style(perception): format streaming lifecycle guards --- .../worker/streaming_profile_stage1/pilot_lifecycle.py | 3 ++- src/k1link/perception/streaming_ingress.py | 4 +--- 2 files changed, 3 insertions(+), 4 deletions(-) diff --git a/experiments/perception/worker/streaming_profile_stage1/pilot_lifecycle.py b/experiments/perception/worker/streaming_profile_stage1/pilot_lifecycle.py index 600d475..90470a9 100644 --- a/experiments/perception/worker/streaming_profile_stage1/pilot_lifecycle.py +++ b/experiments/perception/worker/streaming_profile_stage1/pilot_lifecycle.py @@ -138,7 +138,8 @@ class PilotController: try: if getattr(args, "telemetry_snapshot", None): self.telemetry = RuntimeTelemetryPublisher( - self.runtime, Path(args.telemetry_snapshot), + self.runtime, + Path(args.telemetry_snapshot), "K1 DDRNet + RF-DETR + LiDAR + TGS", ) if control_config: diff --git a/src/k1link/perception/streaming_ingress.py b/src/k1link/perception/streaming_ingress.py index dbe92f9..d6df5f7 100644 --- a/src/k1link/perception/streaming_ingress.py +++ b/src/k1link/perception/streaming_ingress.py @@ -301,9 +301,7 @@ class StreamingIngress: with suppress(RuntimeError): # Already replaced, stopping, or fenced. self.runtime.pause_input( self.input_epoch, - "input-disconnected" - if isinstance(exc, InputInterrupted) - else "source-gap", + "input-disconnected" if isinstance(exc, InputInterrupted) else "source-gap", ) elif self.opened: self.runtime.mailbox.finish(self.error)