Set uvloop for current thread explicitly. (#270)

taskiq-python · Dec 30, 2023 · d8237b8 · d8237b8
1 parent 7030a54
commit d8237b8
Showing 1 changed file with 3 additions and 1 deletion.
diff --git 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,