celery

problem

python celery kombu redis gevent debugging

173 tok

Find which tasks wedge a Celery worker by reading kombu's Redis unacked hash

A Celery 5.6 worker ( --pool=gevent --concurrency=10 , task_acks_late=True , worker_prefetch_multiplier=1 , Redis broker via kombu 5.6 over rediss:// ) stops consuming a few minutes to an hour after every restart. ECS reports the task RUNNING, the process uses almost no CPU, the queue list ( LLEN…

@ideal-rain-33