Celery中使用asyncio触发RuntimeError：主线程无当前事件循环

问题场景 #

在Celery中配置了定时任务（beat_schedule），原本使用普通同步函数，现在尝试在Celery任务中通过asyncio调用异步函数，相关代码如下：

Celery初始化代码：

celery = Celery(
    __name__,
    broker=broker_url,
    backend=backend_url,
    beat_schedule=schedule,
    include=["tasks"],
)

celery.config_from_object(config.get("config"))

celery.conf.update()

logger = get_task_logger(__name__)

if __name__ == "__main__":
    celery.start()

异步调用相关代码：

async def main() -> None:
    await class().method()

@celery.task
def some_task() -> None:
    asyncio.run(main())

运行时触发错误：RuntimeError: There is no current event loop in thread 'MainThread'

错误原因 #

这个错误的核心是Celery的任务执行线程模型与asyncio的事件循环机制不兼容：

• Celery默认采用多线程（或多进程）模型处理任务，当some_task被分配到worker的某个子线程执行时，该线程并非Python的主线程（MainThread）。而asyncio.run()在执行时，会尝试为当前线程创建并绑定事件循环，但它的设计逻辑要求当前线程是主线程，或者该线程没有已存在的事件循环——但Celery的子线程环境下，asyncio无法自动完成事件循环的创建与绑定，因此抛出该错误。
• 另外，asyncio.run()本身是为独立的主线程环境设计的启动入口，并不适合在Celery这种多线程/多进程任务框架的子线程中调用。

内容的提问来源于stack exchange，提问作者AidarDzhumagulov