prod

api/routers/camera_stream.py

@@ -1,4 +1,4 @@
-from backend.domain.detection_box_center import calculate_detection_box_center
+from domain.detection_box_center import calculate_detection_box_center
 from api.dependencies import get_safety_detection_model
 from api.dependencies import get_detection_model, get_depth_model
 import asyncio

services/pipeline.py

@@ -0,0 +1,13 @@
+class ProcessingPipeline:
+    def __init__(self, detector, depth_model, safety_detector, redis_client):
+        self.detector = detector
+        self.depth_model = depth_model
+        self.safety_detector = safety_detector
+        self.redis_client = redis_client
+
+    async def run(self, camera_id:str, image_array):
+
+        # Run ai models
+        # Domain logic
+        # save to infra
+        pass