芹菜中的回调函数

Question

现在我有两个消费者：
task_A.py：

from B import task_b
@app_a.task
def task_a(args):
# do something
task_c.apply_async(args, link=task_a_a.s(args))
@app_a.task
def task_a_a()
# do something

task_B.py：

@app_b.task
def task_b(*args)
# do something
return res

但是我在task_B中遇到错误，就像：

KeyError: 'task_A.task_a_a'

如何使它正确

Answer 1

检查函数task_a中不存在Task_c。

task_c.apply_async(args, link=task_a_a.s(args))

它可能是：

task_b.apply_async(args, link=task_a_a.s(args))