python - 带有redis代理可见性超时的芹菜

Question

我正在尝试实现以下行为：

1. 使用 celery beat 开始 celery 任务
2. 工人被杀
3. 一个新工人发起
4. 任务重新开始

为此，我设置了acks_late=True标志，并且'visibility_timeout': 30

这意味着如果任务在 30 秒内没有确认，则应将新任务添加到队列中

由于某种原因，这不会发生

标签： pythonrediscelery

Answer 1

问题似乎与gevent有关

当我monkey.patch_all()重试机制不起作用时