We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent ee91ae8 commit e2090a6Copy full SHA for e2090a6
taskiq/cli/worker/process_manager.py
@@ -9,7 +9,7 @@
9
from multiprocessing.synchronize import Event as EventType
10
from pathlib import Path
11
from time import sleep
12
-from typing import Any
+from typing import Any, Optional
13
14
try:
15
from watchdog.observers import Observer
@@ -159,7 +159,7 @@ def __init__(
159
self,
160
args: WorkerArgs,
161
worker_function: Callable[[WorkerArgs], None],
162
- observer: Observer | None = None, # type: ignore[valid-type]
+ observer: Optional[Observer] = None, # type: ignore[valid-type] # noqa: UP045
163
) -> None:
164
self.worker_function = worker_function
165
self.action_queue: Queue[ProcessActionBase] = Queue(-1)
0 commit comments