diff --git a/workers/azure_functions_worker/main.py b/workers/azure_functions_worker/main.py index 130e0e9ea..2bd5ddd3b 100644 --- a/workers/azure_functions_worker/main.py +++ b/workers/azure_functions_worker/main.py @@ -3,6 +3,12 @@ """Main entrypoint.""" import argparse +import asyncio +try: + import uvloop + asyncio.set_event_loop_policy(uvloop.EventLoopPolicy()) +except Exception: + pass def parse_args(): @@ -45,8 +51,6 @@ def main(): DependencyManager.initialize() DependencyManager.use_worker_dependencies() - import asyncio - from . import logging from .logging import error_logger, format_exception, logger @@ -56,6 +60,7 @@ def main(): logger.info('Starting Azure Functions Python Worker.') logger.info('Worker ID: %s, Request ID: %s, Host Address: %s:%s', args.worker_id, args.request_id, args.host, args.port) + logger.debug('Using event loop: %s', type(asyncio.get_event_loop())) try: return asyncio.run(start_async( diff --git a/workers/azure_functions_worker/utils/dependency.py b/workers/azure_functions_worker/utils/dependency.py index 76d4259be..3559cef98 100644 --- a/workers/azure_functions_worker/utils/dependency.py +++ b/workers/azure_functions_worker/utils/dependency.py @@ -95,7 +95,7 @@ def should_load_cx_dependencies(cls): ) def use_worker_dependencies(cls): """Switch the sys.path and ensure the worker imports are loaded from - Worker's dependenciess. + Worker's dependencies. This will not affect already imported namespaces, but will clear out the module cache and ensure the upcoming modules are loaded from