@control_command()
def pool_restart(state, modules=None, reload=False, reloader=None, **kwargs):
 if state.app.conf.worker_pool_restarts:
  state.consumer.controller.reload(modules, reload, reloader=reloader)
  return ok(u'reload started')
 else:
  raise ValueError(u'Pool restarts not enabled')

@ control_command ( ) def pool_restart ( state , modules = None , reload = False , reloader = None , ** kwargs ) : if state . app . conf . worker_pool_restarts : state . consumer . controller . reload ( modules , reload , reloader = reloader ) return ok ( u'reload started' ) else : raise ValueError ( u'Pool restarts not enabled' )
restart execution pool .