Обратный вызов apply_async в Django Celery не работает

У меня такой код

@shared_task
def add(a, b):
    return a + b


@shared_task
def add_completed(a, b):
    return a+b

когда я запускаю в оболочке python manage.py shell

>>> from test import add, add_completed
>>> add.apply_async((2,3), link=add.s(10))

результат для этого в моем бэкенде результатов celery

Task Positional Arguments: "(5, 10)"
Result Data: 15
Task Positional Arguments: "(2, 3)"
Result Data: 5

но если я немного изменю код

>>> from test import add, add_completed
>>> add.apply_async((2,3), link=add_completed.s(10))

результат для этого в моем бэкенде результатов celery

Task Positional Arguments: "(2, 3)"

Result Data: {"exc_type": "TypeError", "exc_message": ["add_completed() takes 0 positional arguments but 2 was given"], "exc_module": "builtins"}

Traceback: 

Traceback (most recent call last):
File "/home/ubuntu/src/lib/python3.6/site-packages/celery/app/trace.py", line 505, in trace_task
priority=task_priority
File "/home/ubuntu/src/lib/python3.6/site-packages/celery/canvas.py", line 219, in apply_async
return _apply(args, kwargs, **options)
File "/home/ubuntu/src/lib/python3.6/site-packages/celery/app/task.py", line 537, in apply_async
check_arguments(*(args or ()), **(kwargs or {}))
TypeError: add_completed() takes 0 positional arguments but 2 were given

любая причина, почему он выдает ошибку, и как исправить?

Вернуться на верх