Grow pool by n processes/threads.
(state, n=1, **kwargs)
| 538 | signature='[N=1]', |
| 539 | ) |
| 540 | def pool_grow(state, n=1, **kwargs): |
| 541 | """Grow pool by n processes/threads.""" |
| 542 | if state.consumer.controller.autoscaler: |
| 543 | return nok("pool_grow is not supported with autoscale. Adjust autoscale range instead.") |
| 544 | else: |
| 545 | state.consumer.pool.grow(n) |
| 546 | state.consumer._update_prefetch_count(n) |
| 547 | return ok('pool will grow') |
| 548 | |
| 549 | |
| 550 | @control_command( |
nothing calls this directly
no test coverage detected