'Start the job runner.'

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

    super(PulsarJobRunner, self).__init__(app, nworkers, runner_param_specs=PULSAR_PARAM_SPECS, **kwds)
    self._init_worker_threads()
    galaxy_url = self.runner_params.galaxy_url
    if (not galaxy_url):
        galaxy_url = app.config.galaxy_infrastructure_url
    if galaxy_url:
        galaxy_url = galaxy_url.rstrip('/')
    self.galaxy_url = galaxy_url
    self.__init_client_manager()
    self._monitor()
