Ability to chain tasks - Githubissues

cameronmaske / celery-once

Celery Once allows you to prevent multiple execution and queuing of celery tasks.

https://pypi.python.org/pypi/celery_once/

BSD 2-Clause "Simplified" License

661 stars 90 forks source link

Open Suor opened 4 years ago

Suor commented 4 years ago

I tried with many task dedupe libs including yours and this doesn't work:

(task1.si(42) | task2.s(1)).delay()
(task1.si(42) | task2.s(2)).delay()

I want task1(42) to be deduped and then both task2(1) and task2(2) be ran after it finished. Is this possible?

cameronmaske commented 4 years ago

Hi @Suor It is not currently possible. There was a PR that attempted to introduce this but never made it into master.