Celery状态未更新（停留在PENDING）

Question

我对celery还比较陌生，但我已经在另一个容器上成功实现了分布式工作。现在我在检查celery的工作状态时，发现即使任务显示已经完成，状态依然显示为完成。

这是celery的代码部分：https://github.com/Formartha/ai1899/blob/main/ai1899/tasks.py

如果有人能帮忙解释一下我哪里做错了，我会非常感激。

Answer 1

我觉得你还应该把Celery也启动起来，所以在你的服务器上，应该把这部分改成：

result = uc.AsyncResult(task_id)

改成

from tasks import celery as celery_app

result = uc.AsyncResult(task_id, app=celery_app)

另外，你也可以更通用一点，不指定具体的任务（这样将来其他任务的状态也能适用）：

from tasks import celery as celery_app

result = celery_app.AsyncResult(task_id)