Add DAG-level automatic retries (issue #60866)#63907
Add DAG-level automatic retries (issue #60866)#63907dv-gorasiya wants to merge 4 commits intoapache:mainfrom
Conversation
082c411 to
0b20b69
Compare
0b20b69 to
0d4ef7c
Compare
yuseok89
left a comment
There was a problem hiding this comment.
The CI error seems to be related to migrations-ref.rst. Try running:
prek run --all-filesThis should apply the hook changes and resolve the CI failure.
|
Why actually shall we need to add complexity for dag level retry if we have retries on task level already? I think the same can be achieved by |
|
@jscheffl @dv-gorasiya |
yuseok89
left a comment
There was a problem hiding this comment.
@dv-gorasiya
Please resolve the merge conflicts before we dig deeper into review.
Yes, okay then it is not a "small addition or bugfix" but something that should be first aligned with the development community if such use case should be supported and the additional compelxity is accepted. Scheduling is already complex and adding more parameters, loops and complexity is something that need to be accepted. Can you please add a email to the devliust as [DISCUSS] whether this feature shall be accepted and if the method of implementation is also the right way? |
|
Closing. This need discussion first |
Summary
Implements DAG-level automatic retries for issue #60866.
Changes
dag_try_numberondag_run+ migrationmax_dag_retries/dag_retry_delayon SDK DAG + serialized DAGrun_aftertest_dagrun.pyTesting
pytest airflow-core/tests/unit/models/test_dagrun.py -k dag_level_retryCloses #60866
Gen-AI: This PR was created with assistance from generative AI tools. I have reviewed the code, run the relevant tests, and take responsibility for the contribution.