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