diff --git a/taskiq/cli/worker/run.py b/taskiq/cli/worker/run.py index 24d8f8db..ba923c37 100644 --- a/taskiq/cli/worker/run.py +++ b/taskiq/cli/worker/run.py @@ -124,6 +124,8 @@ def interrupt_handler(signum: int, _frame: Any) -> None: logger.debug("UVLOOP found. Using it as async runner") loop = uvloop.new_event_loop() # type: ignore else: + if sys.platform == "win32": + asyncio.set_event_loop_policy(asyncio.WindowsSelectorEventLoopPolicy()) loop = asyncio.new_event_loop() asyncio.set_event_loop(loop)