working frontend and CI with frontend tests

Author: philippestepniewski

.github/workflows/test.yml

@@ -273,6 +273,14 @@ jobs:
           echo "Launching end-to-end tests"
           uv run pytest tests/tests_end_to_end/test_from_project_creation_to_model_predict.py -v --tb=long
 
+      - name: Install Playwright browser (Chromium)
+        run: uv run playwright install --with-deps chromium
+
+      - name: Run frontend e2e tests
+        run: |
+          echo "Launching frontend e2e tests"
+          uv run pytest tests/tests_end_to_end/test_frontend_e2e.py -v --tb=long
+
       - name: Collect logs on failure
         if: failure()
         run: |

backend/api/health_check.py

@@ -3,7 +3,11 @@
 This module provides a health check endpoint for the API.
 """
 
+import os
+
+import httpx
 from fastapi import APIRouter
+from loguru import logger
 from pydantic import BaseModel
 
 router = APIRouter()
@@ -25,3 +29,28 @@ def health_check():
         A dictionary with the status of the API.
     """
     return HealthCheck(status="OK")
+
+
+@router.get("/storage")
+def storage_health_check():
+    """Check MinIO/S3 storage reachability from the backend.
+
+    Uses the MinIO live health endpoint so the browser never has to reach
+    an internal cluster URL directly.
+
+    Returns
+    -------
+    dict
+        {"status": "ok"} or {"status": "error", "detail": "..."}
+    """
+    s3_url = os.environ.get("MLFLOW_S3_ENDPOINT_URL", "")
+    if not s3_url:
+        return {"status": "error", "detail": "MLFLOW_S3_ENDPOINT_URL not configured"}
+    try:
+        response = httpx.get(f"{s3_url.rstrip('/')}/minio/health/live", timeout=3.0)
+        if response.status_code == 200:
+            return {"status": "ok"}
+        return {"status": "error", "detail": f"HTTP {response.status_code}"}
+    except Exception as e:
+        logger.warning(f"Storage health check failed: {e}")
+        return {"status": "error", "detail": str(e)}

backend/api/projects_routes.py

@@ -13,6 +13,7 @@
 from backend.domain.ports.user_handler import UserHandler
 from backend.domain.use_cases import user_usecases
 from backend.domain.use_cases.auth_usecases import get_current_user, get_user_adapter
+from backend.domain.use_cases.deployed_models import get_registry_status_for_project
 from backend.domain.use_cases.governance_usecases import (
     download_project_models_governance_information,
     return_project_models_governance_information,
@@ -157,8 +158,8 @@ def governance_route(
     try:
         project_governance = return_project_models_governance_information(project_name, registry)
     except Exception as e:
-        logger.warning(f"Could not fetch governance data for project {project_name}: {e}")
-        raise HTTPException(status_code=503, detail=f"MLflow registry unreachable for project '{project_name}'")
+        logger.exception(f"Error fetching governance data for project {project_name}")
+        raise HTTPException(status_code=500, detail=str(e))
     return JSONResponse(content={"project_governance": project_governance}, media_type="application/json")
 
 
@@ -211,3 +212,13 @@ def route_change_user_role_for_project(
     )
     success = user_usecases.change_user_role_for_project(email, project_name, role, user_adapter)
     return JSONResponse(content={"status": success}, media_type="application/json")
+
+
+@router.get("/{project_name}/registry_status")
+def registry_status_route(
+    project_name: str,
+    current_user: dict = Depends(get_current_user),
+):
+    """Return the K8s deployment status of the MLflow registry for a project."""
+    status = get_registry_status_for_project(project_name)
+    return {"status": status}

backend/domain/use_cases/deployed_models.py

@@ -3,6 +3,7 @@
 from backend.domain.entities.model_deployment import ModelDeployment
 from backend.infrastructure.k8s_deployment_cluster_adapter import K8SDeploymentClusterAdapter
 from backend.infrastructure.k8s_registry_deployment_adapter import K8SRegistryDeployment
+from backend.utils import sanitize_project_name
 
 
 def list_deployed_models_with_status_for_a_project(project_name: str) -> list[str]:
@@ -13,6 +14,25 @@ def list_deployed_models_with_status_for_a_project(project_name: str) -> list[st
     return deployed_models_json
 
 
+def get_registry_status_for_project(project_name: str) -> str:
+    """Return the K8s deployment status of the MLflow registry for a project.
+
+    Returns one of: 'running', 'pending', 'error', 'not_found'.
+    """
+    k8s = K8SDeploymentClusterAdapter()
+    namespace = sanitize_project_name(project_name)
+    try:
+        deployments = k8s.apps_api_instance.list_namespaced_deployment(
+            namespace=namespace, label_selector="type=model_registry"
+        )
+        if not deployments.items:
+            return "not_found"
+        return k8s._resolve_deployment_status(deployments.items[0].status)
+    except Exception as e:
+        logger.warning(f"Could not get registry status for {project_name}: {e}")
+        return "error"
+
+
 def _remove_project_namespace(project_name: str) -> None:
     k8s_deployment = K8SRegistryDeployment(project_name)
     k8s_deployment.delete_namespace()

backend/domain/use_cases/governance_usecases.py

@@ -28,9 +28,14 @@ def _extract_model_artifacts(
 
 def _filter_events_for_model(project_events: list, model_name: str, version: str):
     model_events = []
-    for event in project_events:
-        event_entity = event.get("entity").replace("'", '"')
-        event_entity = json.loads(event_entity)
+    for event in project_events or []:
+        raw_entity = event.get("entity")
+        if not raw_entity:
+            continue
+        try:
+            event_entity = json.loads(raw_entity.replace("'", '"'))
+        except (json.JSONDecodeError, AttributeError):
+            continue
         if (
             "model_name" in event_entity
             and event_entity["model_name"] == model_name

pyproject.toml

@@ -54,6 +54,7 @@ dev = [
     "pytest>=8.3.4",
     "pytest-asyncio>=0.25.3",
     "pytest-mock>=3.14.0",
+    "pytest-playwright",
 ]
 notebooks = [
     "pyomo>=6.9.0",