LITE-31450: Support httpx 0.28, add Python 3.12 to test matrix, bump deps

Author: r-s11v

.github/workflows/build.yml

@@ -15,7 +15,7 @@ jobs:
     timeout-minutes: 10
     strategy:
       matrix:
-        python-version: ["3.9", "3.10", "3.11"]
+        python-version: ["3.9", "3.10", "3.11", "3.12"]
     steps:
     - uses: actions/checkout@v3
       with:
@@ -28,7 +28,7 @@ jobs:
       run: |
         python -m pip install --upgrade pip
         pip install poetry
-        poetry install
+        poetry install --all-groups
     - name: Linting
       run: |
         poetry run flake8
@@ -50,7 +50,7 @@ jobs:
         run: |
           python -m pip install --upgrade pip
           pip install poetry
-          poetry install
+          poetry install --all-groups
       - name: Generate coverage report
         run: |
           poetry run pytest

.github/workflows/deploy.yml

@@ -18,7 +18,7 @@ jobs:
       run: |
         python -m pip install --upgrade pip
         pip install poetry
-        poetry install
+        poetry install --all-groups
     - name: Linting
       run: |
         poetry run flake8

connect/eaas/runner/helpers.py

@@ -224,14 +224,17 @@ def notify_process_restarted(process_type):
 
 
 def iter_entry_points(group, name=None):
-    group_entrypoints = entry_points().get(group)
-    if not group_entrypoints:
-        return
-    for ep in group_entrypoints:
-        if name:
-            if ep.name == name:
-                yield ep
-        else:
+    eps = entry_points()
+
+    # Support for Python 3.10+ where .select() is available
+    if hasattr(eps, 'select'):
+        matches = eps.select(group=group)
+    else:
+        # Older versions (pre-3.10)
+        matches = eps.get(group, [])
+
+    for ep in matches:
+        if name is None or ep.name == name:
             yield ep
 
 

connect/eaas/runner/workers/web.py

@@ -39,6 +39,9 @@ class WebWorker(WorkerBase):
     the server and wait for tasks that need to be processed using
     the tasks manager.
     """
+    def __init__(self, *args, **kwargs):
+        super().__init__(*args, **kwargs)
+        self._httpx_app_transport = httpx.ASGITransport(app=self.handler.app)
 
     def get_url(self):
         return self.config.get_webapp_ws_url()
@@ -86,7 +89,7 @@ async def process_task(self, task):
         message = None
         try:
             async with httpx.AsyncClient(
-                app=self.handler.app, base_url='http://localhost',
+                base_url='http://localhost', transport=self._httpx_app_transport,
             ) as client:
                 body = (
                     base64.decodebytes(task.request.content.encode('utf-8'))