'Start the job runner'

def __init__(self, app, nworkers, **kwargs):

    self.app = app
    self.sa_session = app.model.context
    self.nworkers = nworkers
    runner_param_specs = self.DEFAULT_SPECS.copy()
    if ('runner_param_specs' in kwargs):
        runner_param_specs.update(kwargs.pop('runner_param_specs'))
    if kwargs:
        log.debug('Loading    %s    with    params:    %s', self.runner_name, kwargs)
    self.runner_params = RunnerParams(specs=runner_param_specs, params=kwargs)
    self.runner_state_handlers = build_state_handlers()
