celery-dyrygent
celery-dyrygent copied to clipboard
ovh
Celery extension which allows to orchestrate 100/1000/10000 tasks combined into a complex workflow
This is a great package and really helped me with automating large celery workflows. I recently updated my app to use Celery 5 and had continued to use this package...
I'm having some issues with triggering of the on_error task callbacks from chains. I've created a test project here: https://github.com/kriberg/dyrygent-test This defines three tasks: ``` @app.task def normal_task(): log.info("normal task")...
Celery 3. Add integration tests for different backends (redis and mysql). Add integration tests for all supported Python version. Add integration tests for different Celery versions.
Given a task called `echo` like this ```python @app.task def echo(*args, **kwargs): print('echo {} {}'.format(args, kwargs)) return args ``` And then a workflow like this ```python celery_workflow = chain(echo.s(1), echo.s(2))...
It's been a few years since this was released to PyPI and there have been quite a few fixes since. Perhaps we can cut another release of this to the...
hello, may i ask if the relevant parts of this repo have been included in celery-director, or what is the relation between those two OVH celery projects?
