如何使用芹菜定期执行链任务

Question

这里有两个任务。

@app.task(name='add')
def add(x, y):
return x+y

@app.task(name='sub')
def sub(x, y):
return x-y  

然后使用芹菜链完成这两项任务。(我使用的版本是4.20(

我想给这条芹菜链计时

我是这样用的：

@app.on_after_finalize.connect
def setup_periodic_tasks(sender, **kwargs):  
sender.add_periodic_task(
20.0, chain(add.s(1, 9), sub.s(3)), name='run every 20s'
)

但是有这样一个错误：

NotImplementedError: chain is not a real task

怎么办，
芹菜链如何计时，
谢谢

Answer 1

将链包装在常规任务中，然后从调度程序调用它。