Restart execution pool.
(state, modules=None, reload=False, reloader=None, **kwargs)
| 563 | |
| 564 | @control_command() |
| 565 | def pool_restart(state, modules=None, reload=False, reloader=None, **kwargs): |
| 566 | """Restart execution pool.""" |
| 567 | if state.app.conf.worker_pool_restarts: |
| 568 | state.consumer.controller.reload(modules, reload, reloader=reloader) |
| 569 | return ok('reload started') |
| 570 | else: |
| 571 | raise ValueError('Pool restarts not enabled') |
| 572 | |
| 573 | |
| 574 | @control_command( |