python - 如何在芹菜链中设置任务状态

Question

我需要运行三个需要连续运行的任务。因此，当我请求时，我需要按此顺序运行三个任务。每个任务都从前一个任务中获取输入。

Request--->
    [First Task] -> [Second Task] -> [Third Task]

Parent of third = second
Parent of second = first

我需要设置每个子任务的链接请求的状态（使用 ajax 检索状态）。链的 id 等于 [Third Task] 的 id，因此在第三个任务中我可以设置链状态，但如何设置其他两个任务的状态。

Answer 1

你可以做

current_app.AsyncResult({task-id}).[status|results]

其中任务 id 是第一个、第二个、第三个任务。您还可以使用 celery.inspect 查看当前正在计划或执行的任务。