Fix #422

Koed00 · Jun 4, 2020 · b951a19 · b951a19
1 parent 56982bd
commit b951a19
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/django_q/cluster.py b/django_q/cluster.py
@@ -201,7 +201,8 @@ def reincarnate(self, process):
         :param process: the process to reincarnate
         :type process: Process or None
         """
-        close_old_django_connections()
+        if not Conf.SYNC:
+            db.connections.close_all()  # Close any old connections
         if process == self.monitor:
             self.monitor = self.spawn_monitor()
             logger.error(_(f"reincarnated monitor {process.name} after sudden death"))
@@ -225,7 +226,8 @@ def reincarnate(self, process):
     def spawn_cluster(self):
         self.pool = []
         Stat(self).save()
-        close_old_django_connections()
+        if not Conf.SYNC:
+            db.connection.close()
         # spawn worker pool
         for __ in range(self.pool_size):
             self.spawn_worker()