CODEWITHSUNDEEP
pythoncelery
Ari
Ari

Reputation: 6199

Chaining celery task results not working with signatures and kwargs

This is what I was doing, and it was working up until today.

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

I could pass a result from the first task to the next while also setting explicit params. Now it doesnt seem to be passing the result at all, but I still get the kwargs. One day I moved things around and now the result of the first function in the second task comes up as None

Upvotes: 0

Views: 15

Answers (0)

Related Questions