Merge branch 'ask_master'

celery/backends/base.py

@@ -175,7 +175,7 @@ class BaseBackend(object):
                 raise self.get_result(task_id)
             timeout_timer.tick()
 
-    def cleanup_process(self):
+    def process_cleanup(self):
         """Cleanup actions to do at the end of a task worker process.
 
         See :func:`celery.worker.jail`.

celery/backends/tyrant.py

@@ -63,6 +63,7 @@ class Backend(BaseBackend):
     def close(self):
         if self._connection:
             self._connection.close()
+            self._connection = None
 
     def process_cleanup(self):
         self.close()