fixed transport for asynclcient

Author: Andrei Neagu

packages/service-library/tests/fastapi/conftest.py

@@ -10,7 +10,7 @@
 import pytest
 from fastapi import APIRouter, FastAPI
 from fastapi.params import Query
-from httpx import AsyncClient
+from httpx import ASGITransport, AsyncClient
 from pydantic.types import PositiveFloat
 
 
@@ -35,7 +35,9 @@ def _get_data(x: PositiveFloat, y: int = Query(..., gt=3, lt=4)):
 
 @pytest.fixture
 async def client(app: FastAPI) -> AsyncIterator[AsyncClient]:
-    async with AsyncClient(app=app, base_url="http://test") as client:
+    async with AsyncClient(
+        transport=ASGITransport(app=app), base_url="http://test"
+    ) as client:
         yield client
 
 

packages/service-library/tests/fastapi/long_running_tasks/conftest.py

@@ -7,7 +7,7 @@
 
 import pytest
 from fastapi import FastAPI
-from httpx import AsyncClient
+from httpx import ASGITransport, AsyncClient
 from servicelib.fastapi import long_running_tasks
 
 
@@ -22,7 +22,7 @@ async def bg_task_app(router_prefix: str) -> FastAPI:
 @pytest.fixture
 async def async_client(bg_task_app: FastAPI) -> AsyncIterable[AsyncClient]:
     async with AsyncClient(
-        app=bg_task_app,
+        transport=ASGITransport(app=bg_task_app),
         base_url="http://backgroud.testserver.io",
         headers={"Content-Type": "application/json"},
     ) as client:

services/datcore-adapter/tests/unit/conftest.py

@@ -102,7 +102,7 @@ async def initialized_app(
 @pytest.fixture
 async def async_client(initialized_app: FastAPI) -> AsyncIterator[httpx.AsyncClient]:
     async with httpx.AsyncClient(
-        app=initialized_app,
+        transport=httpx.ASGITransport(app=initialized_app),
         base_url="http://datcore-adapter.testserver.io",
         headers={"Content-Type": "application/json"},
     ) as client:

services/dynamic-scheduler/tests/unit/api_rest/conftest.py

@@ -29,7 +29,7 @@ async def client(
     # - Needed for app to trigger start/stop event handlers
     # - Prefer this client instead of fastapi.testclient.TestClient
     async with AsyncClient(
-        app=app,
+        transport=ASGITransport(app=app),
         base_url="http://payments.testserver.io",
         headers={"Content-Type": "application/json"},
     ) as httpx_client:

services/dynamic-sidecar/tests/unit/test_api_rest_containers_long_running_tasks.py

@@ -18,7 +18,7 @@
 from asgi_lifespan import LifespanManager
 from fastapi import FastAPI
 from fastapi.routing import APIRoute
-from httpx import AsyncClient
+from httpx import ASGITransport, AsyncClient
 from models_library.api_schemas_long_running_tasks.base import (
     ProgressMessage,
     ProgressPercent,
@@ -186,7 +186,7 @@ async def httpx_async_client(
 ) -> AsyncIterable[AsyncClient]:
     # crete dir here
     async with AsyncClient(
-        app=app,
+        transport=ASGITransport(app=app),
         base_url=f"{backend_url}",
         headers={"Content-Type": "application/json"},
     ) as client:

services/dynamic-sidecar/tests/unit/test_api_rest_prometheus_metrics.py

@@ -11,7 +11,7 @@
 from aiodocker.volumes import DockerVolume
 from asgi_lifespan import LifespanManager
 from fastapi import FastAPI, status
-from httpx import AsyncClient
+from httpx import ASGITransport, AsyncClient
 from models_library.callbacks_mapping import CallbacksMapping
 from models_library.services_creation import CreateServiceMetricsAdditionalParams
 from pydantic import AnyHttpUrl, TypeAdapter
@@ -70,7 +70,7 @@ async def httpx_async_client(
     cleanup_containers: None,
 ) -> AsyncIterable[AsyncClient]:
     async with AsyncClient(
-        app=app,
+        transport=ASGITransport(app=app),
         base_url=f"{backend_url}",
         headers={"Content-Type": "application/json"},
     ) as client:

services/dynamic-sidecar/tests/unit/test_api_rest_workflow_service_metrics.py

@@ -17,7 +17,7 @@
 from aiodocker.volumes import DockerVolume
 from asgi_lifespan import LifespanManager
 from fastapi import FastAPI
-from httpx import AsyncClient
+from httpx import ASGITransport, AsyncClient
 from models_library.generated_models.docker_rest_api import ContainerState
 from models_library.generated_models.docker_rest_api import Status2 as ContainerStatus
 from models_library.rabbitmq_messages import (
@@ -113,7 +113,9 @@ async def httpx_async_client(
 ) -> AsyncIterable[AsyncClient]:
     # crete dir here
     async with AsyncClient(
-        app=app, base_url=f"{backend_url}", headers={"Content-Type": "application/json"}
+        transport=ASGITransport(app=app),
+        base_url=f"{backend_url}",
+        headers={"Content-Type": "application/json"},
     ) as client:
         yield client
 

services/payments/tests/unit/api/conftest.py

@@ -20,7 +20,7 @@ async def client(app: FastAPI) -> AsyncIterator[httpx.AsyncClient]:
     # - Needed for app to trigger start/stop event handlers
     # - Prefer this client instead of fastapi.testclient.TestClient
     async with httpx.AsyncClient(
-        app=app,
+        transport=ASGITransport(app=app),
         base_url="http://payments.testserver.io",
         headers={"Content-Type": "application/json"},
     ) as client:

services/payments/tests/unit/api/test_rest_acknowledgements.py

@@ -77,7 +77,6 @@ async def client(
             external_base_url,
         )
         async with httpx.AsyncClient(
-            app=None,
             base_url=external_base_url,
             headers={"Content-Type": "application/json"},
         ) as new_client:

services/resource-usage-tracker/tests/unit/conftest.py

@@ -135,7 +135,7 @@ def client(app_settings: ApplicationSettings) -> Iterator[TestClient]:
 @pytest.fixture
 async def async_client(initialized_app: FastAPI) -> AsyncIterator[httpx.AsyncClient]:
     async with httpx.AsyncClient(
-        app=initialized_app,
+        transport=httpx.ASGITransport(app=initialized_app),
         base_url=f"http://{initialized_app.title}.testserver.io",
         headers={"Content-Type": "application/json"},
     ) as client: