gpt4 book ai didi

celery - 在 celery 中打破无限循环

转载 作者:行者123 更新时间:2023-12-05 00:30:56 46 4
gpt4 key购买 nike

我使用 celery.chord(...) 创建一组任务和一个方法,该方法在组中的所有任务完成后被调用。

我使用 amqp 结果后端(但我想切换到 memcached)。

我的 worker 每秒钟一遍又一遍地打印这条线。我不知道如何打破这个无限循环。我可以访问 rabbitMQ Web 界面,但找不到 ID 为“32ba5fe4-...”的内容。

[2013-03-22 14:18:26,896: INFO/MainProcess] Task celery.chord_unlock[32ba5fe4-918c-480f-8a78-a310c11d0c3a] retry: Retry in 1s
[2013-03-22 14:18:26,897: INFO/MainProcess] Got task from broker: celery.chord_unlock[32ba5fe4-918c-480f-8a78-a310c11d0c3a] eta:[2013-03-22 13:18:27.895123+00:00]

这是一个测试环境。任何数据都不会丢失。

我使用 celery 3.0.16

最佳答案

它不应该是一个无限循环。

celery.chord_unlock 任务检查和弦子任务是否完成以调用合并回调任务。如果不是,它会安排自己在一秒钟内再次检查。完成和弦任务后,您将不再在日志中看到这些消息。

编辑:您可以撤销 chord_unlock 任务以停止循环

celery.control.revoke('32ba5fe4-918c-480f-8a78-a310c11d0c3a')

关于celery - 在 celery 中打破无限循环,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/15571557/

46 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com