incrementing and decrementing

celery/worker/control.py

@@ -284,7 +284,7 @@ def pool_grow(state, n=1, **kwargs):
     else:
         state.consumer.pool.grow(n)
     state.consumer.qos.increment_eventually(n)
-    state.consumer.initial_prefetch_count = n
+    state.consumer.initial_prefetch_count += n
     return {'ok': 'spawned worker processes'}
 
 
@@ -295,7 +295,7 @@ def pool_shrink(state, n=1, **kwargs):
     else:
         state.consumer.pool.shrink(n)
     state.consumer.qos.decrement_eventually(n)
-    state.consumer.initial_prefetch_count = n
+    state.consumer.initial_prefetch_count -= n
     return {'ok': 'terminated worker processes'}