This is an automated email from the ASF dual-hosted git repository. jedcunningham pushed a commit to branch v2-4-test in repository https://gitbox.apache.org/repos/asf/airflow.git
commit 25f601168f990a1fb16bba3a8335ff8933bf41ed Author: David Katz <[email protected]> AuthorDate: Fri Sep 9 14:18:43 2022 +0300 Add the dag_id to AirflowDagCycleException message (#26204) (cherry picked from commit aada79e1dabe729362ddd8a3c7eb43efb8fc1c17) --- airflow/utils/dag_cycle_tester.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/airflow/utils/dag_cycle_tester.py b/airflow/utils/dag_cycle_tester.py index ef587f6ba8..5109ba7d4f 100644 --- a/airflow/utils/dag_cycle_tester.py +++ b/airflow/utils/dag_cycle_tester.py @@ -58,7 +58,7 @@ def check_cycle(dag: 'DAG') -> None: """Returns first untraversed child task, else None if all tasks traversed.""" for adjacent_task in current_task.get_direct_relative_ids(): if visited[adjacent_task] == CYCLE_IN_PROGRESS: - msg = f"Cycle detected in DAG. Faulty task: {task_id}" + msg = f"Cycle detected in DAG: {dag.dag_id}. Faulty task: {task_id}" raise AirflowDagCycleException(msg) elif visited[adjacent_task] == CYCLE_NEW: return adjacent_task
