Fixed #18

jcass77 · Apr 14, 2018 · 567aeed · 567aeed
1 parent 0f9224d
commit 567aeed
Showing 1 changed file with 6 additions and 2 deletions.
diff --git a/django_apscheduler/models.py b/django_apscheduler/models.py
@@ -31,8 +31,12 @@ def __ping(self):
 
     def __reconnect(self):
         LOGGER.warning("Mysql closed the connection. Perform reconnect...")
-        connection.connection.close()
-        connection.connection = None
+
+        if connection.connection:
+            connection.connection.close()
+            connection.connection = None
+        else:
+            LOGGER.warning("Connection was already closed.")
 
 
 class DjangoJob(models.Model):