Run tasks after another without using result of first task in second task

Question

I have two celery tasks task1 and task2 which write to database. The third task task3 reads from the same database. task1 and task2 can run in parallel. task3 will run after both task1 and task2 have run.

I have looked at groups, chains and chords but can't get around to a place where I can run task3 without passing the arguments of task1 and task2 to it. I just want the sequence to be maintained

Any help in this direction is highly appreciated. Basically to run xsquare task at the last

@app.task
def xsum():
    return sum(i + i for i in range(100))

@app.task
def xmult():
    return sum(i * i for i in range(100))

@app.task
def xsquare():
    return sum(i * i for i in range(100))

xsum_mult = group(xsum.s(), xmult.s())

xsum_mult.apply_async()

# now run xsquare task

DejanLekic · Accepted Answer · 2023-03-04 12:14:49Z

1

It should be as simple as using the immutable signatures. Scroll down to "The Primitives" section and you will see how to use immutable signatures in a chain.

answered Mar 4, 2023 at 12:14

DejanLekic

20k4 gold badges53 silver badges84 bronze badges

Sign up to request clarification or add additional context in comments.

1 Comment

Aditya Ganguli Over a year ago

Thanks for this. Basically I have just started ignoring the arguments being passed, but this should resolve as well

Collectives™ on Stack Overflow

Run tasks after another without using result of first task in second task

1 Answer 1

1 Comment

Your Answer

Hot Network Questions

Collectives™ on Stack Overflow

1 Answer 1

1 Comment

Your Answer

Sign up or log in

Post as a guest

Related