ovh / celery-director

Simple and rapid framework to build workflows with Celery
https://ovh.github.io/celery-director/
BSD 3-Clause "New" or "Revised" License
534 stars 58 forks source link

payload modification #195

Closed wqhhust closed 1 year ago

wqhhust commented 1 year ago

Currently the only way to pass parameter from one step to anther is only possible in the case of parent & child relationship using args, but this is too limited. I will much better if we can even pass parameter from a step to a much deeper/later step (children of children...), this can't be done by simply using args. One possible way is to enable us to modify payload, so that if we want to add a parameter for later step, we just use kwargs["payload"]["new_param_name']="param_value"

ncrocfer commented 1 year ago

This feature request is not really linked to Director, but rather to Celery itself no?

Don't forget that Celery Director is just a wrapper on top of Celery.

For information on our side this usecase is fixed by a Redis instance (we store the result from a task then we get it from another one).

wqhhust commented 1 year ago

Got it, thx. Let me close it.