fixes

Author: HardMax71

backend/app/db/repositories/execution_repository.py

@@ -143,7 +143,7 @@ async def get_executions(
                     created_at=doc.get("created_at", datetime.now(timezone.utc)),
                     updated_at=doc.get("updated_at", datetime.now(timezone.utc)),
                     resource_usage=(
-                        ResourceUsageDomain.from_dict(dict(resource_usage_data))
+                        ResourceUsageDomain.from_dict(resource_usage_data)
                         if resource_usage_data is not None
                         else None
                     ),

backend/tests/conftest.py

@@ -126,9 +126,9 @@ def create_test_app():
 
 
 # ===== App without lifespan for tests =====
-@pytest_asyncio.fixture(scope="function")
+@pytest_asyncio.fixture(scope="session")
 async def app():
-    """Create FastAPI app for the function without starting lifespan."""
+    """Create FastAPI app once per session/worker to avoid Pydantic schema crashes."""
     application = create_test_app()
 
     yield application
@@ -138,7 +138,7 @@ async def app():
         await container.close()
 
 
-@pytest_asyncio.fixture(scope="function")
+@pytest_asyncio.fixture(scope="session")
 async def app_container(app):  # type: ignore[valid-type]
     """Expose the Dishka container attached to the app."""
     container: AsyncContainer = app.state.dishka_container  # type: ignore[attr-defined]

backend/tests/fixtures/real_services.py

@@ -311,33 +311,37 @@ async def ensure_services_running():
     import subprocess
 
     # Check MongoDB
-    try:
+    async def check_mongo() -> None:
         client = AsyncMongoClient(
             "mongodb://root:rootpassword@localhost:27017",
             serverSelectionTimeoutMS=5000
         )
-        await client.admin.command("ping")
-        await client.close()
+        try:
+            await client.admin.command("ping")
+        finally:
+            await client.close()
+
+    try:
+        await check_mongo()
     except Exception:
         print("Starting MongoDB...")
         subprocess.run(["docker-compose", "up", "-d", "mongo"], check=False)
-        await wait_for_service(
-            lambda: AsyncMongoClient("mongodb://root:rootpassword@localhost:27017").admin.command("ping"),
-            service_name="MongoDB"
-        )
-    
+        await wait_for_service(check_mongo, service_name="MongoDB")
+
     # Check Redis
-    try:
+    async def check_redis() -> None:
         r = redis.Redis(host="localhost", port=6379, socket_connect_timeout=5)
-        await r.execute_command("PING")
-        await r.aclose()
+        try:
+            await r.execute_command("PING")
+        finally:
+            await r.aclose()
+
+    try:
+        await check_redis()
     except Exception:
         print("Starting Redis...")
         subprocess.run(["docker-compose", "up", "-d", "redis"], check=False)
-        await wait_for_service(
-            lambda: redis.Redis(host="localhost", port=6379).execute_command("PING"),
-            service_name="Redis"
-        )
+        await wait_for_service(check_redis, service_name="Redis")
 
     # Kafka is optional - don't fail if not available
     try:

backend/tests/integration/db/schema/test_schema_manager.py

@@ -28,7 +28,8 @@ async def test_apply_all_idempotent_and_creates_indexes(db) -> None:  # type: ig
 
     # Verify some expected indexes exist
     async def idx_names(coll: str) -> set[str]:
-        lst = await db[coll].list_indexes().to_list(length=None)
+        cursor = await db[coll].list_indexes()
+        lst = await cursor.to_list(length=None)
         return {i.get("name", "") for i in lst}
 
     # events

backend/tests/integration/services/saved_script/test_saved_script_service.py

@@ -6,8 +6,6 @@
 
 pytestmark = [pytest.mark.integration, pytest.mark.mongodb]
 
-pytestmark = pytest.mark.integration
-
 
 def _create_payload() -> DomainSavedScriptCreate:
     return DomainSavedScriptCreate(name="n", description=None, script="print(1)")