Python Celery Task.update_state가 영구적으로 차단됩니다.

Question

Celery current_task를 사용하여 작업 진행 상황을 업데이트하고 있습니다. 시간의 99 %가 무한히 멈추게됩니다. RabbitMQ 백엔드 셀러리 3.0.x의은

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

[UPDATE]

그래서 셀러리 AMQP 백엔드에서 발생하는 교착있을 표시

def _store_result(self, task_id, result, status, traceback=None): 
    """Send task return value and status.""" 
    with self.mutex: 
     with self.app.amqp.producer_pool.acquire(block=True) as pub: 
      .......... 

는

Answer 1

모습 용액 조사 이 문제는 kombu 연결 풀 한도로 인해 broker_pool_limit를 기본값 인

에서 늘려 해결할 수있었습니다.

BROKER_POOL_LIMIT=100