

def run():
    logger = logs.prepare_submodule_logger('receiverd', settings.RPC_CONSUMER_LOG_PATH)
    logger.info('Starting standalone RPC consumer...')
    with Connection(rpc.conn_str) as conn:
        try:
            RPCConsumer(conn, NailgunReceiver).run()
        except (KeyboardInterrupt, SystemExit):
            logger.info('Stopping standalone RPC consumer...')

dataset/ETHPy150Open openstack/fuel-web/nailgun/nailgun/rpc/receiverd.py run/original