django - 我如何将参数传递给 celery 任务？

Question

这是我的 celery 任务

def task_a(arg1, arg2, arg3, arg4)

我把这个任务称为如下

arg1 是列表，arg2,3,4 是整数

task_a.apply_async(arg1, arg2, arg3, arg4)

我收到一条错误信息

    File "/opt/envDjango/lib/python3.5/site-packages/celery/app/task.py", line 518, in apply_async
    check_arguments(*(args or ()), **(kwargs or {}))
    TypeError: functools.partial object argument after ** must be a mapping, not int

我该如何解决问题？？

我试图制作字典并更改参数位置，但它们都失败了...

Answer 1

delay将代替 apply_async 起作用: 见文档 here

task_a.delay(*arg,**kwargs)