Close the sessions before disposing the engines as the engines won't …

…close connections held up in sessions.
cblp · Mar 22, 2014 · 7be5028 · 7be5028
1 parent 688c3fe
commit 7be5028
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/celery/backends/database/session.py b/celery/backends/database/session.py
@@ -29,10 +29,12 @@ class _after_fork(object):
 
     def __call__(self):
         self.registered = False  # child must reregister
+        for session in _SESSIONS:
+            session.close()
+        _SESSIONS.clear()
         for engine in list(_ENGINES.values()):
             engine.dispose()
         _ENGINES.clear()
-        _SESSIONS.clear()
 after_fork = _after_fork()