on_process_started renamed -> on_process_up

celery/concurrency/base.py

@@ -47,7 +47,7 @@ class BasePool(object):
     _pool = None
 
     #: only used by multiprocessing pool
-    on_process_started = None
+    on_process_up = None
 
     #: only used by multiprocessing pool
     on_process_down = None

celery/concurrency/processes/__init__.py

@@ -108,16 +108,16 @@ class TaskPool(BasePool):
                 "put-guarded-by-semaphore": self.putlocks,
                 "timeouts": (self._pool.soft_timeout, self._pool.timeout)}
 
-    def set_on_process_started(self, callback):
-        self._pool.on_process_created
+    def set_on_process_up(self, callback):
+        self._pool.on_process_up
 
-    def _get_on_process_started(self):
-        return self._pool.on_process_started
+    def _get_on_process_up(self):
+        return self._pool.on_process_up
 
-    def _set_on_process_started(self, fun):
-        self._pool.on_process_started = fun
-    on_process_started = property(_get_on_process_started,
-                                  _set_on_process_started)
+    def _set_on_process_up(self, fun):
+        self._pool.on_process_up = fun
+    on_process_up = property(_get_on_process_up,
+                             _set_on_process_up)
 
     def _get_on_process_down(self):
         return self._pool.on_process_down

celery/worker/consumer.py

@@ -406,9 +406,9 @@ class Consumer(object):
             for handler, interval in self.pool.timers.iteritems():
                 self.timer.apply_interval(interval * 1000.0, handler)
 
-            def on_process_started(w):
+            def on_process_up(w):
                 hub.add(w._popen.sentinel, self.pool._pool.maintain_pool)
-            self.pool.on_process_started = on_process_started
+            self.pool.on_process_up = on_process_up
 
             def on_process_down(w):
                 hub.remove(w._popen.sentinel)