如何使用异步概念在Celery中设计一个调用另一个子任务的任务

问题描述

因此，当您尝试在celery任务中使用.get（）时，celery中会出现错误：RuntimeError：切勿在任务内调用result.get（）！

简单示例：

@app.task
def parent_task():
    a = do_something()
    b = subtask_b().apply_async().get()
    c = do_something_with_a_and_b(a,b)
    return c

@app.task
def subtask_b():
    do_something_b()

我查看了许多文档，包括：https://docs.celeryproject.org/en/stable/userguide/tasks.html#task-synchronous-subtasks

我仍然对如何正确设计工作流（如下面的示例）感到困惑。我知道有一些解决方法可以忽略该错误并调用get（）。但是，处理此类任务的常用设计是什么。是否需要对功能进行彻底的重新设计，以便在parent_task中不调用subtask_b，以便能够进行链接。

解决方法

暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！

如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@）