new module

Author: pcrespov

packages/pytest-simcore/src/pytest_simcore/asyncio_event_loops.py

@@ -0,0 +1,39 @@
+import asyncio
+
+import pytest
+import uvloop
+
+pytest_plugins = [
+    "aiohttp.pytest_plugin",  # No need to install pytest-aiohttp separately
+]
+
+
+@pytest.fixture(scope="session")
+def event_loop_policy():
+    """Override the event loop policy to use uvloop which is the one we use in production
+
+    SEE https://pytest-asyncio.readthedocs.io/en/stable/how-to-guides/uvloop.html
+    """
+    return uvloop.EventLoopPolicy()
+
+
+@pytest.fixture
+async def loop() -> asyncio.AbstractEventLoop:
+    """Override the event loop inside aiohttp.pytest_plugin with the one from pytest-asyncio.
+
+
+        Otherwise error like this will be raised:
+
+    >        if connector._loop is not loop:
+    >           raise RuntimeError("Session and connector has to use same event loop")
+    E           RuntimeError: Session and connector has to use same event loop
+
+    .venv/lib/python3.11/site-packages/aiohttp/client.py:375: RuntimeError
+
+    >        if connector._loop is not loop:
+    >           raise RuntimeError("Session and connector has to use same event loop")
+    >E           RuntimeError: Session and connector has to use same event loop
+
+    .venv/lib/python3.11/site-packages/aiohttp/client.py:375: RuntimeError
+    """
+    return asyncio.get_running_loop()

services/web/server/tests/conftest.py

@@ -3,7 +3,6 @@
 # pylint: disable=unused-argument
 # pylint: disable=unused-variable
 
-import asyncio
 import contextlib
 import json
 import logging
@@ -66,6 +65,7 @@
 # imports the fixtures for the integration tests
 pytest_plugins = [
     "aiohttp.pytest_plugin",
+    "pytest_simcore.asyncio_event_loops",
     "pytest_simcore.cli_runner",
     "pytest_simcore.db_entries_mocks",
     "pytest_simcore.docker_compose",
@@ -488,9 +488,3 @@ def mock_dynamic_scheduler(mocker: MockerFixture) -> None:
         "simcore_service_webserver.dynamic_scheduler.api.update_projects_networks",
         autospec=True,
     )
-
-
-@pytest.fixture
-async def loop() -> asyncio.AbstractEventLoop:
-    """Override the event loop inside pytest-aiohttp with the one from pytest-asyncio."""
-    return asyncio.get_running_loop()