diff --git a/airflow/models/taskinstance.py b/airflow/models/taskinstance.py index a55ea0fe77e52..c3bf25e343008 100644 --- a/airflow/models/taskinstance.py +++ b/airflow/models/taskinstance.py @@ -3492,6 +3492,7 @@ def _schedule_downstream_tasks( run_id=ti.run_id, ), session=session, + nowait=True, ).one() task = ti.task