Skip to content

Commit 48fcd68

Browse files
committed
fix: Remove duplicate mark_task_as_started listener
Only one of the listeners was unsubscribed so they would pile up in the WorkerEvent publisher.
1 parent 2e8842f commit 48fcd68

1 file changed

Lines changed: 0 additions & 1 deletion

File tree

src/blueapi/worker/task_worker.py

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -318,7 +318,6 @@ def mark_task_as_started(event: WorkerEvent, _: str | None) -> None:
318318
sub = self.worker_events.subscribe(mark_task_as_started)
319319
try:
320320
self._current_task_otel_context = get_current()
321-
sub = self.worker_events.subscribe(mark_task_as_started)
322321
""" Cache the current trace context as the one for this task id """
323322
self._task_channel.put_nowait(trackable_task)
324323
task_started.wait(timeout=5.0)

0 commit comments

Comments
 (0)