python - 通过 task_id 重试 celery 中的任务

Question

我已经启动了很多任务，但其中一些还没有完成（763 个任务），处于 PENDING 状态，但系统没有处理任何事情......可以重试这个任务，给 celery 任务 ID？

Answer 1

你不能。您只能从内部重试任务，不能从外部执行。

在这种情况下，最好的办法是使用相同的 args 再次运行任务类型，这样您将执行相同的 JOB，但使用标识您的进程/任务的新 PID。

还要记住，celery PENDING 状态不仅意味着任务正在等待执行，而且可能是未知的。

http://celeryq.org/docs/userguide/tasks.html#pending

我希望这会有所帮助