still initial commit

app.py

@@ -29,8 +29,12 @@ def get_modal_backend():
 # ── Core Backend Execution ──────────────────────────────────────────────────
 def run_modal_backend(frame: np.ndarray) -> np.ndarray:
     """Compresses the frame, sends it to Modal, and decodes the returned bytes."""
-    backend = get_modal_backend()
-    if backend is None:
+    # Look up dynamically to prevent cross-thread event loop pollution
+    try:
+        VoxelModelCls = modal.Cls.from_name("flux-klein-voxel-backend", "VoxelModel")
+        backend = VoxelModelCls().process_frame
+    except Exception as e:
+        print(f"❌ Failed to resolve Modal class: {e}")
         return frame
 
     # Compress to JPEG to save network bandwidth
@@ -39,7 +43,7 @@ def run_modal_backend(frame: np.ndarray) -> np.ndarray:
         return frame
 
     try:
-        # Fire bytes to Modal serverless container
+        # Fire bytes to Modal serverless container synchronously
         processed_bytes = backend.remote(encoded.tobytes())
         # Decode the returning bytes back into an OpenCV image
         result = cv2.imdecode(np.frombuffer(processed_bytes, dtype=np.uint8), cv2.IMREAD_COLOR)
@@ -52,28 +56,26 @@ def run_modal_backend(frame: np.ndarray) -> np.ndarray:
                     cv2.FONT_HERSHEY_SIMPLEX, 0.7, (0, 0, 255), 2)
         return err_frame
 
-
 # ── Activation & Pre-Warming Logic ──────────────────────────────────────────
 def start_and_warmup_container():
     """Forces the Modal container to start up before enabling the webcam stream."""
     print("🚀 [START CLICKED] Waking up Modal container to prevent cold-start lag...")
-    
-    backend = get_modal_backend()
-    if backend is not None:
-        try:
-            # Create a tiny 1x1 blank image payload
-            dummy_frame = np.zeros((1, 1, 3), dtype=np.uint8)
-            success, encoded = cv2.imencode(".jpg", dummy_frame)
-            if success:
-                # Trigger a remote execution to force container ignition
-                backend.remote(encoded.tobytes())
-                print("✅ [CONTAINER READY] Modal container is hot and ready for frames.")
-        except Exception as e:
-            print(f"ℹ️ [CONTAINER NOTIFICATION] Warmup call dispatched: {e}")
-            
+    try:
+        VoxelModelCls = modal.Cls.from_name("flux-klein-voxel-backend", "VoxelModel")
+        backend = VoxelModelCls().process_frame
+        
+        # Create a tiny 1x1 blank image payload
+        dummy_frame = np.zeros((1, 1, 3), dtype=np.uint8)
+        success, encoded = cv2.imencode(".jpg", dummy_frame)
+        if success:
+            print("⏳ Sending ignition payload to remote container...")
+            backend.remote(encoded.tobytes())
+            print("✅ [CONTAINER READY] Modal container is hot and ready for frames.")
+    except Exception as e:
+        print(f"ℹ️ [CONTAINER NOTIFICATION] Warmup pipeline updated: {e}")
+        
     return True
 
-
 # ── Streaming Logic ─────────────────────────────────────────────────────────
 def process_video_stream(frame: np.ndarray, mode: str, is_running: bool) -> np.ndarray:
     """Handles the webcam feed and respects the Start/Stop toggle."""