diff --git a/django_q/cluster.py b/django_q/cluster.py index f0d8d68..343c5ca 100644 --- a/django_q/cluster.py +++ b/django_q/cluster.py @@ -188,6 +188,7 @@ class Sentinel(object): def spawn_cluster(self): self.pool = [] Stat(self).save() + db.connection.close() # spawn worker pool for __ in range(self.pool_size): self.spawn_worker()