eladkal commented on code in PR #36935:
URL: https://github.com/apache/airflow/pull/36935#discussion_r1525323732
##########
airflow/models/dag.py:
##########
@@ -364,6 +364,8 @@ class DAG(LoggingMixin):
:param max_active_runs: maximum number of active DAG runs, beyond this
number of DAG runs in a running state, the scheduler won't create
new active DAG runs
+ :param max_consecutive_failed_dag_runs:(experimental) maximum number of
consecutive failed DAG runs,
Review Comment:
```suggestion
:param max_consecutive_failed_dag_runs: (experimental) maximum number of
consecutive failed DAG runs,
```
##########
airflow/config_templates/config.yml:
##########
@@ -116,6 +116,17 @@ core:
type: string
example: ~
default: "16"
+ max_consecutive_failed_dag_runs_per_dag:
+ description: |
+ (experimental) The maximum number of consecutive DAG failures before
DAG is automatically paused.
+ This is also configurable per DAG level with
``max_consecutive_failed_dag_runs``,
+ which is defaulted as ``max_consecutive_failed_dag_runs_per_dag``.
+ If not specified, then the value is considered as 0,
+ meaning that the dags are never paused out by default.
+ version_added: ~
Review Comment:
```suggestion
version_added: 2.9.0
```
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
