问
如何在芹菜链中设置第一个任务的任务ID？
北斗七星 发布于 2023-01-10 12:43我有类似的东西
from uuid import uuid4 task_id = uuid4() (task1.s(args..) | task2.s() | task3.s()).apply_async(task_id=task_id)
现在我希望这个自定义task_id是第一个任务的任务ID,task1但是当我尝试从task1使用中记录它时它是不同的self.request.id
如何在此处设置自定义ID？
1 个回答
-
如果你想通过TASK_ID在您链的第一个任务,你应该调用
.subtask()哪个比暴露更多的选择.s()或.si():from celery.utils import uuid first_task_id = uuid() (task1.subtask(args=(..), task_id=first_task_id) | task2.s() | task3.s()).apply_async()
2023-01-10 12:45 回答
愤然尔立_980
撰写答案
今天，你开发时遇到什么问题呢？
立即提问
京公网安备 11010802041100号