diff --git a/taskiq/cli/worker/process_manager.py b/taskiq/cli/worker/process_manager.py index 097f031..2763261 100644 --- a/taskiq/cli/worker/process_manager.py +++ b/taskiq/cli/worker/process_manager.py @@ -159,7 +159,7 @@ def __init__( self, args: WorkerArgs, worker_function: Callable[[WorkerArgs], None], - observer: Observer | None = None, # type: ignore[valid-type] + observer: "Observer | None" = None, # type: ignore[valid-type] ) -> None: self.worker_function = worker_function self.action_queue: Queue[ProcessActionBase] = Queue(-1)