Celery Group 任务完成但 completed_count 为零

Question

我正在使用 Celery 4.3.0 创建一组要运行的任务。当我这样做时，任务本身都成功执行，但 GroupResult 完成计数始终为 0。

我用的是rabbitmq broker，试过redis result backend和db result backend，效果一样。

@shared_task(
    autoretry_for=(Exception,), retry_backoff=
    ignore_result=False, retry_kwargs={'max_retries': 3},
)
def some_task(*args, **kwargs):
    logger.info('some task')


def run_tasks():
   tasks = [some_task.s(), some_task.s()]
   result = group(*tasks).apply_async()
   while True:
       print(result.completed_count())

Answer 1

您可以将 celery 更新到 4.4.1。我在更新之前遇到了同样的问题。