diff --git a/src/blueapi/service/runner.py b/src/blueapi/service/runner.py index 2b5a5f37f..7fa6d9251 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: @@ -110,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], 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.