celery-director
celery-director copied to clipboard
ovh
Simple and rapid framework to build workflows with Celery
In order to improve the monitoring experience on the UI I added a description field to the workflows table. This way it is possible to add specific information to each...
Celery chord callbacks work differently with redis vs postgres/rabbitmq result backends and require the use of polling with an internal celery task. This results in an unhandled exception being thrown...
Add link to Celery director documentation in the navbar full screen:  small screen  
Some improvements have to be done: **V1** - include the pytz package in the requirements.txt - use ISO8601 date format in the next_run key - the pagination is not useful,...
Reading the documentation I know that celery-director can run tasks in parallel https://ovh.github.io/celery-director/guides/build-workflows/#launch-tasks-in-parallel But I have a question related to this feature. What is the definition to run the same...
psycog2-binary should not be used in the production package release. see: https://www.psycopg.org/docs/install.html#psycopg-vs-psycopg-binary https://github.com/psycopg/psycopg2/issues/674
I am trying to create a below-defined workflow and it is giving error ``` p.TEST: tasks: - TEST_1 - TEST_2 - WORKERS: type: group tasks: - TEST_3 - TEST3_WORKERS: type:...
Hi guys, It would be great to have the option to define a workflow in Python instead of only in YAML. From the workflows engines that I know, maybe Prefect...
Handle hooks in the `workflows.yml` file. Example: ``` demo.EXAMPLE: tasks: - EXTRACT_TASK - TRANSFORM_TASK - LOAD_TASK hooks: success: SUCCESS_TASK failure: FAILURE_TASK ```
Currently, all other tasks in the workflow is in pending status if any task in the workflow fails. Need to add a cancelled status in this case
