def _run_worker():
    LOG.info('(PID=%s) Exporter started.', os.getpid())
    export_worker = worker.get_worker()
    try:
        export_worker.start(wait=True)
    except (KeyboardInterrupt, __HOLE__):
        LOG.info('(PID=%s) Exporter stopped.', os.getpid())
        export_worker.shutdown()
    except:
        return 1
    return 0
dataset/ETHPy150Open StackStorm/st2/st2exporter/st2exporter/cmd/st2exporter_starter.py/_run_worker