diff --git a/airflow-core/src/airflow/models/dagrun.py b/airflow-core/src/airflow/models/dagrun.py index 20ec118f33e79..7eabadd73cfb6 100644 --- a/airflow-core/src/airflow/models/dagrun.py +++ b/airflow-core/src/airflow/models/dagrun.py @@ -2005,6 +2005,8 @@ def schedule_tis( # to render start_from_trigger in the scheduler. If we need to # render the value in a worker, it kind of defeats the purpose of # this feature (which is to save a worker process if possible). + # Re-enabled on main by #55068 but not backported to 3.2; + # decision tracked at https://github.com/apache/airflow/issues/66307 # elif task.start_trigger_args is not None: # if task.expand_start_from_trigger(context=ti.get_template_context()): # ti.start_date = timezone.utcnow() diff --git a/airflow-core/tests/unit/models/test_dagrun.py b/airflow-core/tests/unit/models/test_dagrun.py index 6aa4fc84c76ec..93bf2dcbdf428 100644 --- a/airflow-core/tests/unit/models/test_dagrun.py +++ b/airflow-core/tests/unit/models/test_dagrun.py @@ -2260,6 +2260,11 @@ def test_schedule_tis_only_one_scheduler_update_succeeds_when_competing(dag_make assert refreshed_ti.try_number == 1 +@pytest.mark.skip( + reason="start_from_trigger scheduling path is disabled on v3-2-test " + "(re-enabled on main by #55068, not backported); " + "tracked at https://github.com/apache/airflow/issues/66307" +) @pytest.mark.need_serialized_dag def test_schedule_tis_start_trigger(dag_maker, session): """