Re: [PR] Add ability to automatically set DAG to off after X times it failed sequentially [airflow]

pateash commented on code in PR #36935: URL: https://github.com/apache/airflow/pull/36935#discussion_r1468545330 ## airflow/models/dagrun.py: ## @@ -498,6 +498,37 @@ def fetch_task_instances( tis = tis.where(TI.task_id.in_(task_ids)) return session.scalars(

Re: [PR] Add ability to automatically set DAG to off after X times it failed sequentially [airflow]

BasPH commented on code in PR #36935: URL: https://github.com/apache/airflow/pull/36935#discussion_r1464581185 ## airflow/models/dagrun.py: ## @@ -498,6 +498,37 @@ def fetch_task_instances( tis = tis.where(TI.task_id.in_(task_ids)) return session.scalars(ti

Re: [PR] Add ability to automatically set DAG to off after X times it failed sequentially [airflow]

dirrao commented on code in PR #36935: URL: https://github.com/apache/airflow/pull/36935#discussion_r1464253181 ## airflow/models/dagrun.py: ## @@ -498,6 +498,37 @@ def fetch_task_instances( tis = tis.where(TI.task_id.in_(task_ids)) return session.scalars(t