Python中使用break终止异步for循环触发Task pending销毁报错的问题咨询

错误原因 #

当你通过break终止async for循环时，异步生成器messages_iter的迭代被中断，但它内部的异步任务没有被妥善关闭，Python在程序退出或清理资源时发现仍有处于pending状态的Task，因此抛出警告。

另外你的代码存在缩进错误：message_list.append(message)和message_count += 1的缩进层级错误，虽当前逻辑下结果可能一致，但属于不规范写法，容易引发其他逻辑问题。

解决方案 #

方法一：手动关闭异步生成器 #

使用try-finally块确保无论循环是否提前终止，都能调用异步生成器的aclose()方法，彻底关闭内部任务：

messages_iter = client.get_chat_history(config["chat_id"])

messages_list = []
message_count = 0
try:
    async for message in messages_iter: 
        if message_count == 5:
            break
        messages_list.append(message)
        message_count += 1
finally:
    await messages_iter.aclose()

方法二：使用上下文管理器（若生成器支持） #

如果client.get_chat_history返回的异步生成器实现了异步上下文管理器接口（支持async with），可以用这种更简洁的写法，上下文管理器会自动处理生成器的关闭：

messages_list = []
message_count = 0
async with client.get_chat_history(config["chat_id"]) as messages_iter:
    async for message in messages_iter: 
        if message_count == 5:
            break
        messages_list.append(message)
        message_count += 1

内容的提问来源于stack exchange，提问作者ai-py