def start()

in proxy_worker/start_worker.py [0:0]


def start():
    from .utils.dependency import DependencyManager
    DependencyManager.initialize()
    DependencyManager.use_worker_dependencies()

    import asyncio

    from . import logging
    from .logging import error_logger, logger

    args = parse_args()
    logging.setup(log_level="INFO", log_destination=None)

    logger.info("Args: %s", args)
    logger.info(
        'Starting proxy worker. Worker ID: %s, Request ID: %s, Host Address: %s:%s',
        args.worker_id, args.request_id, args.host, args.port)

    try:
        return asyncio.run(start_async(
            args.host, args.port, args.worker_id, args.request_id))
    except Exception as ex:
        error_logger.exception(
            'unhandled error in functions worker: {0}'.format(
                ''.join(traceback.format_exception(ex))))
        raise