【发布时间】:2011-07-05 16:06:43
【问题描述】:
我已经启动了很多任务,但其中一些还没有完成(763 个任务),处于 PENDING 状态,但系统没有处理任何事情...... 是否可以重试此任务,为 celery 提供 task_id?
【问题讨论】:
标签: python distributed celery celery-task
我已经启动了很多任务,但其中一些还没有完成(763 个任务),处于 PENDING 状态,但系统没有处理任何事情...... 是否可以重试此任务,为 celery 提供 task_id?
【问题讨论】:
标签: python distributed celery celery-task
你不能。 您只能从内部重试任务,而不能从外部重试。
在这种情况下,最好的办法是使用相同的 args 再次运行任务类型,这样您将执行相同的 JOB,但使用标识您的进程/任务的新 PID。
还要记住,celery PENDING 状态不仅意味着任务正在等待执行,而且可能是未知的。
http://celeryq.org/docs/userguide/tasks.html#pending
希望对你有帮助
【讨论】:
my_task.apply_async(args, task_id=uuid)