From f0546bc91cf2c961d58b9c15cbf5bad6487912df Mon Sep 17 00:00:00 2001
From: Martijn Jacobs <maerteijn@gmail.com>
Date: Fri, 1 May 2020 17:30:19 +0200
Subject: [PATCH] Lock the Scheduler model for the database it's using

This can happen when you use a database router for example
---
 django_q/cluster.py | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/django_q/cluster.py b/django_q/cluster.py
index c6bffae..cb2877d 100644
--- a/django_q/cluster.py
+++ b/django_q/cluster.py
@@ -546,7 +546,7 @@ def scheduler(broker=None):
         broker = get_broker()
     close_old_django_connections()
     try:
-        with db.transaction.atomic():
+        with db.transaction.atomic(using=Schedule.objects.db):
             for s in (
                 Schedule.objects.select_for_update()
                 .exclude(repeats=0)