Browse Source

Fixes eventlet pool memory leak. Closes #308

Ask Solem 14 years ago
parent
commit
1c1e8be25b
1 changed files with 2 additions and 2 deletions
  1. 2 2
      celery/concurrency/evlet.py

+ 2 - 2
celery/concurrency/evlet.py

@@ -103,5 +103,5 @@ class TaskPool(base.BasePool):
 
 
     def on_apply(self, target, args=None, kwargs=None, callback=None,
     def on_apply(self, target, args=None, kwargs=None, callback=None,
             accept_callback=None, **_):
             accept_callback=None, **_):
-        self._pool.spawn(apply_target, target, args, kwargs,
-                         callback, accept_callback)
+        self._pool.spawn_n(apply_target, target, args, kwargs,
+                           callback, accept_callback)