Python芹菜Task.update_状态潜在的障碍

Question

我正在使用芹菜当前任务更新任务进度。它99%的时间都能工作，然后无限期地挂起。celery 3.0.x与RabbitMQ后端

current_task.update_state(state=state,
            meta= { 'progress' : progress })

[更新]

所以celery amqp后端似乎出现了死锁

^{pr2}$

研究解决方案

Answer 1

看起来这是kombu连接池限制的问题，可以通过将broker_pool_限制从默认值增加来解决此问题

BROKER_POOL_LIMIT=100