使用asyncio.create_task遇‘coroutine was never awaited’错误如何解决？

错误含义 #

coroutine was never awaited错误表示你创建了一个协程对象（调用async函数的返回值），但既没有用await等待它执行完成，也没将它作为任务提交给asyncio事件循环调度。协程本质是可暂停的函数，必须被明确调度才能运行，否则Python会判定这是未处理的协程，触发该错误。

问题分析与修复 #

从你提供的代码来看，问题大概率出在以下几点：

1. send_turn_queue_update若为协程函数，直接调用未处理 #

如果self.send_turn_queue_update()是async函数，直接调用它会生成一个未被处理的协程对象，这正是触发错误的核心原因。你需要将其包装为后台任务：

# 在next_turn函数中修改这一行
asyncio.create_task(self.send_turn_queue_update())

如果该函数不需要后台运行，也可以用await等待它完成，但这会阻塞next_turn的执行，不符合你后台任务的需求。

2. 协程取消时的异常处理（可选优化） #

当你调用self._turn_worker.cancel()时，被取消的_turn_end_timer协程会在await asyncio.sleep处抛出CancelledError。虽然asyncio会自动处理这个异常，但为了优雅退出，可以添加捕获逻辑：

async def _turn_end_timer(self):
    try:
        await asyncio.sleep(self.turn_time)
        self.next_turn()
    except asyncio.CancelledError:
        # 这里可以添加取消时的清理逻辑，比如释放资源
        pass

3. 确保所有协程都被正确调度 #

检查代码中所有调用async函数的地方，确保每个协程对象要么被await等待，要么被asyncio.create_task()包装后提交给事件循环。任何直接调用async def函数却不处理返回值的行为，都会触发该错误。

4. 事件循环启动的优化（可选） #

你当前的事件循环启动方式是可行的，但Python 3.7+推荐更简洁的写法：

async def main():
    # 你的主逻辑代码
    pass

if __name__ == "__main__":
    loop = asyncio.get_event_loop()
    loop.run_until_complete(main())
    loop.run_forever()

注意asyncio.run()会在执行完毕后关闭事件循环，因此如果需要持续运行事件循环，还是使用上述方式。

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