我正在创建一个 eta 介于 3 到 20 小时之间的任务,当我查看工作日志时,对于这个任务,工作人员Got task from broker: ...
在收到原始任务后每小时都会说“”,直到达到 eta。
我知道这与设置BROKER_TRANSPORT_OPTIONS = {'visibility_timeout': X}
X 是以秒为单位的数字有关。
所以我玩了 visibility_timeout,如果我将它设置为小于 1 小时,那么我可以看到工作人员每 X 秒执行一次相同的任务,但是当我将visibility_timeout
X 设置为大于 1 小时时,它会保持默认为 1h,不管我设定的时间。
还有其他人遇到这个问题吗?这是一个已知的错误吗?
我正在使用带有 Redis 服务器版本 2.4.15 的 Celery 3.0.11 (Chiastic Slide)