From 0a855f27d040e14ba2a189e0b332387055d4afc5 Mon Sep 17 00:00:00 2001 From: Joseph Ware <53935796+DiamondJoseph@users.noreply.github.com> Date: Tue, 21 Oct 2025 14:07:43 +0100 Subject: [PATCH 1/2] fix: Prevent spans being swallowed by infinite startup span --- src/blueapi/service/runner.py | 1 - src/blueapi/worker/task_worker.py | 1 - 2 files changed, 2 deletions(-) diff --git a/src/blueapi/service/runner.py b/src/blueapi/service/runner.py index 2b5a5f37f..f6b19e359 100644 --- a/src/blueapi/service/runner.py +++ b/src/blueapi/service/runner.py @@ -71,7 +71,6 @@ def reload(self): self.start() LOGGER.info("Runner reloaded") - @start_as_current_span(TRACER) def start(self): environment_id = uuid.uuid4() try: diff --git a/src/blueapi/worker/task_worker.py b/src/blueapi/worker/task_worker.py index 06055cc93..7537a0c8b 100644 --- a/src/blueapi/worker/task_worker.py +++ b/src/blueapi/worker/task_worker.py @@ -370,7 +370,6 @@ def state(self) -> WorkerState: """ return self._state - @start_as_current_span(TRACER) def run(self) -> None: """ Run all tasks that are submitted to the worker. Blocks thread. From 34fd60312caa70f66904582c737d261c2ce394cd Mon Sep 17 00:00:00 2001 From: Joseph Ware <53935796+DiamondJoseph@users.noreply.github.com> Date: Tue, 21 Oct 2025 14:08:08 +0100 Subject: [PATCH 2/2] fix: Remove further trace --- src/blueapi/service/runner.py | 1 - 1 file changed, 1 deletion(-) diff --git a/src/blueapi/service/runner.py b/src/blueapi/service/runner.py index f6b19e359..7fa6d9251 100644 --- a/src/blueapi/service/runner.py +++ b/src/blueapi/service/runner.py @@ -109,7 +109,6 @@ def stop(self): error_message=_safe_exception_message(e), ) - @start_as_current_span(TRACER, "function", "args", "kwargs") def run( self, function: Callable[P, T],