fix:

api/routers/camera_stream.py

@@ -1,4 +1,4 @@
-from backend.services.pipeline import ProcessingPipeline
+from services.pipeline import ProcessingPipeline
 from api.dependencies import get_safety_detection_model
 from api.dependencies import get_detection_model, get_depth_model
 import asyncio

services/pipeline.py

@@ -1,11 +1,11 @@
-from backend.api.routers.metrics import depth_duration_seconds
-from backend.api.routers.metrics import detection_duration_seconds
-from backend.api.routers.metrics import decode_duration_seconds
-from backend.utils.profiling import profile_step
-from backend.domain.detection_box_center import calculate_detection_box_center
+from api.routers.metrics import depth_duration_seconds
+from api.routers.metrics import detection_duration_seconds
+from api.routers.metrics import decode_duration_seconds
+from utils.profiling import profile_step
+from domain.detection_box_center import calculate_detection_box_center
 import asyncio
-from backend.contracts.camera_metadata import DetectionMetadata
-from backend.contracts.camera_metadata import CameraMetadata
+from contracts.camera_metadata import DetectionMetadata
+from contracts.camera_metadata import CameraMetadata
 import cv2 as cv
 import numpy as np
 

tests/test_pipeline.py

@@ -1,4 +1,4 @@
-from backend.services.pipeline import ProcessingPipeline
+from services.pipeline import ProcessingPipeline
 import pytest
 import numpy as np
 from unittest.mock import MagicMock, AsyncMock, patch
@@ -33,7 +33,7 @@ async def test_pipeline_success(mock_deps):
 
     with (
         patch("cv2.imdecode") as mock_decode,
-        patch("backend.utils.profiling.mlflow") as mock_mlflow,
+        patch("utils.profiling.mlflow") as _,
     ):
         mock_decode.return_value = np.zeros((100, 100, 3), dtype=np.uint8)
 
@@ -60,7 +60,7 @@ async def test_pipeline_no_detections(mock_deps):
 
     with (
         patch("cv2.imdecode") as mock_decode,
-        patch("backend.utils.profiling.mlflow") as mock_mlflow,
+        patch("utils.profiling.mlflow") as _,
     ):
         mock_decode.return_value = np.zeros((100, 100, 3), dtype=np.uint8)