still initial commit

app.py

@@ -28,9 +28,8 @@ else:
         voxel_backend = None
         status_text = "🔴 Offline (Connection Error)"
 
-
 # ── Core Backend Execution ──────────────────────────────────────────────────
-def run_modal_backend(frame: np.ndarray) -> np.ndarray:
+async def run_modal_backend(frame: np.ndarray) -> np.ndarray:
     """Compresses the frame, sends it to Modal, and decodes the returned bytes."""
     if voxel_backend is None:
         return frame
@@ -41,8 +40,8 @@ def run_modal_backend(frame: np.ndarray) -> np.ndarray:
         return frame
 
     try:
-        # Fire bytes to Modal serverless container
-        processed_bytes = voxel_backend.remote(encoded.tobytes())
+        # Fire bytes to Modal serverless container ASYNCHRONOUSLY
+        processed_bytes = await voxel_backend.remote.aio(encoded.tobytes())
         # Decode the returning bytes back into an OpenCV image
         result = cv2.imdecode(np.frombuffer(processed_bytes, dtype=np.uint8), cv2.IMREAD_COLOR)
         return result if result is not None else frame
@@ -56,7 +55,7 @@ def run_modal_backend(frame: np.ndarray) -> np.ndarray:
 
 
 # ── Activation & Pre-Warming Logic ──────────────────────────────────────────
-def start_and_warmup_container():
+async 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...")
     
@@ -66,19 +65,17 @@ def start_and_warmup_container():
             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
-                voxel_backend.remote(encoded.tobytes())
+                # Trigger a remote execution to force container ignition ASYNCHRONOUSLY
+                await voxel_backend.remote.aio(encoded.tobytes())
                 print("✅ [CONTAINER READY] Modal container is hot and ready for frames.")
         except Exception as e:
-            # Catching gracefully in case the backend throws an error on 1x1 dimensions,
-            # the container will still have been forced to start up regardless.
             print(f"ℹ️ [CONTAINER NOTIFICATION] Warmup call dispatched: {e}")
             
     return True
 
 
 # ── Streaming Logic ─────────────────────────────────────────────────────────
-def process_video_stream(frame: np.ndarray, mode: str, is_running: bool) -> np.ndarray:
+async def process_video_stream(frame: np.ndarray, mode: str, is_running: bool) -> np.ndarray:
     """Handles the webcam feed and respects the Start/Stop toggle."""
     if frame is None:
         return None
@@ -88,8 +85,8 @@ def process_video_stream(frame: np.ndarray, mode: str, is_running: bool) -> np.n
     if not is_running:
         return frame
 
-    # 1. Process the frame through the Modal network
-    processed = run_modal_backend(frame)
+    # 1. Process the frame through the Modal network (AWAIT IT)
+    processed = await run_modal_backend(frame)
 
     # 2. Format the output based on the selected UI mode
     if mode == "Minecraft Filter":