Explorar el Código

method rename from cleanup_process -> process_cleanup

Vitaly Babiy hace 16 años
padre
commit
32bb0ff632
Se han modificado 1 ficheros con 1 adiciones y 1 borrados
  1. 1 1
      celery/worker.py

+ 1 - 1
celery/worker.py

@@ -78,7 +78,7 @@ def jail(task_id, func, args, kwargs):
         cache.cache.close()
 
     # Backend process cleanup
-    default_backend.cleanup_process()
+    default_backend.process_cleanup()
 
     # Convert any unicode keys in the keyword arguments to ascii.
     kwargs = dict([(k.encode("utf-8"), v)