当前位置：文江博客话题详情

通过任务 ID 重试 celery 中的任务

发布于 2024-10-19 16:28:36 字数 96 浏览 8 评论 0原文

我启动了很多任务，但其中一些尚未完成（763 个任务），处于 PENDING 状态，但系统未处理任何内容... 是否可以通过给 celery 提供 task_id 来重试此任务？

原文

分享到QQ

分享到微博

如果你对这篇内容有疑问，欢迎到本站社区发帖提问参与讨论，获取更多帮助，或者扫码二维码加入 Web 技术交流群。

发布评论

需要登录才能够评论，你可以免费注册一个本站的账号。

物价感观 2024-10-26 16:28:36

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

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

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

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

我希望这能有所帮助

回复收藏 0 原文

行至春深 2024-10-26 16:28:36

现在，在设置 celery.conf.update(result_extended=True) 后，它可以保留传递给任务的参数：

def retry_task(task_id):    
    meta=celery.backend.get_task_meta(task_id)
    task = celery.tasks[meta['name']]
    task.apply_async(args=meta['args'], kwargs=meta['kwargs']) #specify any other parameters you might be passing

This works now after setting celery.conf.update(result_extended=True) which persists the arguments passed to the task:

def retry_task(task_id):    
    meta=celery.backend.get_task_meta(task_id)
    task = celery.tasks[meta['name']]
    task.apply_async(args=meta['args'], kwargs=meta['kwargs']) #specify any other parameters you might be passing

回复收藏 0 原文

~没有更多了~