fix

Author: Evan Roman

azure_functions_worker_v1/tests/unittests/test_logging.py

@@ -29,4 +29,4 @@ def raising_function():
             self.assertIn("call2", processed_exception)
             self.assertIn("f", processed_exception)
             self.assertRegex(processed_exception,
-                             r".*tests\\unittests\\test_logging.py.*")
+                             r".*tests/unittests/test_logging.py.*")

azure_functions_worker_v2/tests/unittests/test_logging.py

@@ -29,4 +29,4 @@ def raising_function():
             self.assertIn("call2", processed_exception)
             self.assertIn("f", processed_exception)
             self.assertRegex(processed_exception,
-                             r".*tests\\unittests\\test_logging.py.*")
+                             r".*tests/unittests/test_logging.py.*")

eng/ci/public-build.yml

@@ -65,6 +65,7 @@ extends:
         - template: /eng/templates/jobs/ci-unit-tests.yml@self
           parameters:
             PROJECT_DIRECTORY: 'workers'
+            PoolName: 1es-pool-azfunc-public
     - stage: RunWorkerEmulatorTests
       dependsOn: BuildPythonWorker
       jobs:

eng/pack/templates/macos_64_env_gen.yml

@@ -86,6 +86,7 @@ steps:
       !python/**
       !tests/**
       !setuptools*/**
+      !uvloop/**
       !_distutils_hack/**
       !distutils-precedence.pth
       !pkg_resources/**

eng/pack/templates/nix_arm64_env_gen.yml

@@ -92,6 +92,7 @@ steps:
       !python/**
       !tests/**
       !setuptools*/**
+      !uvloop/**
       !_distutils_hack/**
       !distutils-precedence.pth
       !pkg_resources/**

eng/pack/templates/nix_env_gen.yml

@@ -86,6 +86,7 @@ steps:
       !python/**
       !tests/**
       !setuptools*/**
+      !uvloop/**
       !_distutils_hack/**
       !distutils-precedence.pth
       !pkg_resources/**

eng/templates/jobs/ci-unit-tests.yml

@@ -4,6 +4,11 @@ parameters:
 jobs:
   - job: "TestPython"
     displayName: "Run Python Unit Tests"
+
+    pool:
+      name: ${{ parameters.PoolName }}
+      image: 1es-ubuntu-22.04
+      os: linux
 
     strategy:
       matrix:

workers/azure_functions_worker/main.py

@@ -4,11 +4,11 @@
 
 import argparse
 import asyncio
-# try:
-#     import uvloop
-#     asyncio.set_event_loop_policy(uvloop.EventLoopPolicy())
-# except Exception:
-#     pass
+try:
+    import uvloop
+    asyncio.set_event_loop_policy(uvloop.EventLoopPolicy())
+except Exception:
+    pass
 
 
 def parse_args():

workers/proxy_worker/start_worker.py

@@ -5,11 +5,11 @@
 import argparse
 import traceback
 import asyncio
-# try:
-#     import uvloop
-#     asyncio.set_event_loop_policy(uvloop.EventLoopPolicy())
-# except Exception:
-#     pass
+try:
+    import uvloop
+    asyncio.set_event_loop_policy(uvloop.EventLoopPolicy())
+except Exception:
+    pass
 
 _GRPC_CONNECTION_TIMEOUT = 5.0
 

workers/pyproject.toml

@@ -39,6 +39,7 @@ dependencies = [
      "grpcio~=1.43.0; python_version == '3.7'",
      "grpcio ~=1.59.0; python_version >= '3.8' and python_version < '3.13'",
      "grpcio~=1.70.0; python_version >= '3.13'",
+     "uvloop~=0.21.0; python_version >= '3.13'",
      "azurefunctions-extensions-base; python_version >= '3.8'",
      "azure-functions-runtime==1.0.0a3; python_version >= '3.13'",
      "azure-functions-runtime-v1==1.0.0b1; python_version >= '3.13'"