flake

Author: hallvictoria

eng/templates/jobs/ci-dependency-check.yml

@@ -12,10 +12,6 @@ jobs:
 
     strategy:
       matrix:
-        Python39:
-          PYTHON_VERSION: '3.9'
-        Python310:
-          PYTHON_VERSION: '3.10'
         Python311:
           PYTHON_VERSION: '3.11'
         Python312:

workers/proxy_worker/dispatcher.py

@@ -12,7 +12,6 @@
 from asyncio import AbstractEventLoop
 from dataclasses import dataclass
 from typing import Any, Optional
-import packaging
 
 import grpc
 

workers/tests/unittests/check_imports.py

@@ -56,25 +56,25 @@ def find_imports(src_dir):
                         imports.add("azurefunctions.extensions.base")
                     # Special cases to ignore
                     elif str(src_dir).startswith("workers") and (
-                        node.module == "azure.monitor.opentelemetry"
-                        or node.module == "opentelemetry"
-                        or node.module == "opentelemetry.trace.propagation.tracecontext"
-                        or node.module == "Cookie"):
+                            node.module == "azure.monitor.opentelemetry"
+                            or node.module == "opentelemetry"
+                            or node.module == "opentelemetry.trace.propagation.tracecontext" # noqa
+                            or node.module == "Cookie"):
                         pass
-                    elif str(src_dir).startswith("runtimes\\v1\\azure_functions_runtime_v1") and (
-                        node.module == "google.protobuf.timestamp_pb2"
-                        or node.module == "azure.monitor.opentelemetry"
-                        or node.module == "opentelemetry"
-                        or node.module == "opentelemetry.trace.propagation.tracecontext"
-                        or node.module == "Cookie"):
+                    elif str(src_dir).startswith("runtimes\\v1\\azure_functions_runtime_v1") and ( # noqa
+                            node.module == "google.protobuf.timestamp_pb2"
+                            or node.module == "azure.monitor.opentelemetry"
+                            or node.module == "opentelemetry"
+                            or node.module == "opentelemetry.trace.propagation.tracecontext" # noqa
+                            or node.module == "Cookie"):
                         pass
-                    elif str(src_dir).startswith("runtimes\\v2\\azure_functions_runtime") and (
-                        node.module == "google.protobuf.duration_pb2"
-                        or node.module == "google.protobuf.timestamp_pb2"
-                        or node.module == "azure.monitor.opentelemetry"
-                        or node.module == "opentelemetry"
-                        or node.module == "opentelemetry.trace.propagation.tracecontext"
-                        or node.module == "Cookie"):
+                    elif str(src_dir).startswith("runtimes\\v2\\azure_functions_runtime")and ( # noqa
+                            node.module == "google.protobuf.duration_pb2"
+                            or node.module == "google.protobuf.timestamp_pb2"
+                            or node.module == "azure.monitor.opentelemetry"
+                            or node.module == "opentelemetry"
+                            or node.module == "opentelemetry.trace.propagation.tracecontext" # noqa
+                            or node.module == "Cookie"):
                         pass
                     else:
                         imports.add(node.module.split(".")[0])
@@ -119,8 +119,6 @@ def check_package(pkg_root, package_name):
         ):
             missing.append(imp)
 
-
-
     if missing:
         print("Missing required dependencies:")
         for m in missing:

workers/tests/utils/testutils_docker.py

@@ -69,7 +69,9 @@ def find_latest_image(image_repo: str,
                           image_url: str) -> str:
 
         # New regex to match version format: 4.1042.100-4-python3.11
-        regex = re.compile(_HOST_VERSION + r'\.10\d+\.\d+(-\d+)?-python' + _python_version + r'(-appservice)?$')
+        regex = re.compile(_HOST_VERSION
+                           + r'\.10\d+\.\d+(-\d+)?-python'
+                           + _python_version + r'(-appservice)?$')
 
         response = requests.get(image_url, allow_redirects=True)
         if not response.ok:
@@ -91,10 +93,13 @@ def find_latest_image(image_repo: str,
         # getting the latest released runtime version for python.
         # Parse version format: 4.1042.100-4-python3.11
         def parse_version(tag):
-            version_part = tag.split('-python')[0]  # "4.1042.100-4"
-            parts = version_part.replace('-', '.').split('.')  # ["4", "1042", "100", "4"]
-            return tuple(int(p) for p in parts)  # (4, 1042, 100, 4)
-        
+            # "4.1042.100-4"
+            version_part = tag.split('-python')[0]
+            # ["4", "1042", "100", "4"]
+            parts = version_part.replace('-', '.').split('.')
+            # (4, 1042, 100, 4)
+            return tuple(int(p) for p in parts)
+
         latest_version = sorted(python_versions, key=parse_version)[-1]
 
         image_tag = f'{image_repo}:{latest_version}'