From e36cfe8760be62d9dac76604f50a9a14c6af88d4 Mon Sep 17 00:00:00 2001 From: Peter Holloway Date: Fri, 6 Mar 2026 13:05:06 +0000 Subject: [PATCH] fix: Remove duplicate mark_task_as_started listener Only one of the listeners was unsubscribed so they would pile up in the WorkerEvent publisher. --- src/blueapi/worker/task_worker.py | 1 - 1 file changed, 1 deletion(-) diff --git a/src/blueapi/worker/task_worker.py b/src/blueapi/worker/task_worker.py index adcfe366d3..caa39fe7a0 100644 --- a/src/blueapi/worker/task_worker.py +++ b/src/blueapi/worker/task_worker.py @@ -318,7 +318,6 @@ def mark_task_as_started(event: WorkerEvent, _: str | None) -> None: sub = self.worker_events.subscribe(mark_task_as_started) try: self._current_task_otel_context = get_current() - sub = self.worker_events.subscribe(mark_task_as_started) """ Cache the current trace context as the one for this task id """ self._task_channel.put_nowait(trackable_task) task_started.wait(timeout=5.0)