Результаты задачи цепочки сельдерея не работают с подписями и Kwargs ⇐ Python

[Anonymous]

Это то, что я делал, и это работало до сегодняшнего дня.

Код: Выделить всё

workflow = chain(
signature(
"my.task",
args=(1, 2, 3),
options={"queue": "default"},
),
signature(
"my.other.task",
kwargs={
"explicity_param1": 10,
"explicit_param2": 12,
},
options={"queue": "default"},
),
)()

@shared_task(bind=true, name="my.task")
def my_task(self, a, b, c)
return a + b + c

@shared_task(bind=true, name="my.other.task")
def my_other_task(self, from_task, explicity_param1, explicity_param2)
return from_task + explicity_param1 + explicity_param2
< /code>
Я мог бы перенести результат из первой задачи к следующей, а также настройка явных параметров. Теперь это, похоже, вообще не передает результат, но я все еще получаю Kwargs. Однажды я перевел все, и теперь результат первой функции во второй задаче возникает, когда нет 

Подробнее здесь: https://stackoverflow.com/questions/794 ... and-kwargs