|
@@ -283,6 +283,8 @@ def pool_grow(state, n=1, **kwargs):
|
|
state.consumer.controller.autoscaler.force_scale_up(n)
|
|
state.consumer.controller.autoscaler.force_scale_up(n)
|
|
else:
|
|
else:
|
|
state.consumer.pool.grow(n)
|
|
state.consumer.pool.grow(n)
|
|
|
|
+ state.consumer.qos.increment_eventually(n)
|
|
|
|
+ state.consumer.initial_prefetch_count = n
|
|
return {'ok': 'spawned worker processes'}
|
|
return {'ok': 'spawned worker processes'}
|
|
|
|
|
|
|
|
|
|
@@ -292,6 +294,8 @@ def pool_shrink(state, n=1, **kwargs):
|
|
state.consumer.controller.autoscaler.force_scale_down(n)
|
|
state.consumer.controller.autoscaler.force_scale_down(n)
|
|
else:
|
|
else:
|
|
state.consumer.pool.shrink(n)
|
|
state.consumer.pool.shrink(n)
|
|
|
|
+ state.consumer.qos.decrement_eventually(n)
|
|
|
|
+ state.consumer.initial_prefetch_count = n
|
|
return {'ok': 'terminated worker processes'}
|
|
return {'ok': 'terminated worker processes'}
|
|
|
|
|
|
|
|
|