Skip to content

Commit

Permalink
Add 'max_consecutive_failed_dag_runs' to DAG schema
Browse files Browse the repository at this point in the history
In the DAG schema, 'max_consecutive_failed_dag_runs' has been added. This attribute determines the threshold for how many consecutive failures will result in the DAG being paused. This will improve error handling, ensuring DAGs are paused promptly if they are consistently failing.
  • Loading branch information
pateash committed Feb 5, 2024
1 parent 6df778f commit 394d028
Showing 1 changed file with 4 additions and 0 deletions.
4 changes: 4 additions & 0 deletions tests/api_connexion/schemas/test_dag_schema.py
Original file line number Diff line number Diff line change
Expand Up @@ -65,6 +65,7 @@ def test_serialize_test_dag_schema(url_safe_serializer):
"next_dagrun_data_interval_start": None,
"next_dagrun_data_interval_end": None,
"max_active_runs": 16,
"max_consecutive_failed_dag_runs": 0,
"next_dagrun_create_after": None,
"last_expired": None,
"max_active_tasks": 16,
Expand Down Expand Up @@ -105,6 +106,7 @@ def test_serialize_test_dag_collection_schema(url_safe_serializer):
"next_dagrun_create_after": None,
"last_expired": None,
"max_active_tasks": 16,
"max_consecutive_failed_dag_runs": 0,
"last_pickled": None,
"default_view": None,
"last_parsed_time": None,
Expand Down Expand Up @@ -133,6 +135,7 @@ def test_serialize_test_dag_collection_schema(url_safe_serializer):
"next_dagrun_create_after": None,
"last_expired": None,
"max_active_tasks": 16,
"max_consecutive_failed_dag_runs": 0,
"last_pickled": None,
"default_view": None,
"last_parsed_time": None,
Expand Down Expand Up @@ -189,6 +192,7 @@ def test_serialize_test_dag_detail_schema(url_safe_serializer):
"template_searchpath": None,
"timezone": UTC_JSON_REPR,
"max_active_runs": 16,
"max_consecutive_failed_dag_runs": 0,
"pickle_id": None,
"end_date": None,
"is_paused_upon_creation": None,
Expand Down

0 comments on commit 394d028

Please sign in to comment.