diff --git a/taskiq/cli/worker/run.py b/taskiq/cli/worker/run.py index 09c71b0..055148e 100644 --- a/taskiq/cli/worker/run.py +++ b/taskiq/cli/worker/run.py @@ -117,7 +117,9 @@ def interrupt_handler(signum: int, _frame: Any) -> None: loop = uvloop.new_event_loop() # type: ignore else: loop = asyncio.new_event_loop() - asyncio.set_event_loop(loop) + + asyncio.set_event_loop(loop) + # This option signals that current # broker is running as a worker. # We must set this field before importing tasks,