From cf7cd58fead16e1a2675cc9251678c282a21836f Mon Sep 17 00:00:00 2001
From: Daniel Standish <15932138+dstandish@users.noreply.github.com>
Date: Wed, 10 Apr 2024 14:11:27 -0700
Subject: [PATCH] Don't wait for DagRun lock in mini scheduler

We should just bail if something else is already "minischeduling".  We already catch OperationalError so there's nothing else we need to change for this.
---
 airflow/models/taskinstance.py | 1 +
 1 file changed, 1 insertion(+)

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