diff --git a/tests/operators/test_watcher.py b/tests/operators/test_watcher.py index ed33d1a7b6..0738cd9332 100644 --- a/tests/operators/test_watcher.py +++ b/tests/operators/test_watcher.py @@ -1990,9 +1990,12 @@ def test_dbt_dag_with_watcher_and_failing_model(caplog): @pytest.mark.skipif( - AIRFLOW_VERSION < Version("2.10") or (Version("3.1.0") <= AIRFLOW_VERSION < Version("3.2.0")), + AIRFLOW_VERSION < Version("2.10") or (Version("3.0.0") <= AIRFLOW_VERSION < Version("3.2.0")), reason=( "dag.test() in Airflow 2.9 hangs when a task fails with retries configured. " + "Airflow 3.0 runs tasks inline via _run_raw_task without the task SDK supervisor, " + "so RuntimeTaskInstance.get_task_states raises NameError for SUPERVISOR_COMMS and " + "the watcher sensor cannot detect producer termination on retry. " "Airflow 3.1.x crashes during task finalization (SetRenderedFields) when retrying " "tasks inside a DbtTaskGroup via dag.test()." ),