Update server.py

server.py

@@ -1,4 +1,8 @@
-
+#!/usr/bin/env python3
+"""
+FastAPI Video Compression Server
+Continuously polls Hugging Face dataset for large videos and compresses them.
+"""
 
 import os
 import sys
@@ -257,9 +261,14 @@ async def scan_and_compress_videos():
         video_files = []
         for f in files:
             if f.startswith(f"{READY_VIDEOS_FOLDER}/") and f.endswith(".mp4"):
+                # Skip already compressed files
+                if "_compressed" in f:
+                    print(f"  ⊘ {f.split('/')[-1]} (already compressed file)")
+                    continue
+                
                 # Skip if already handled
                 if f in compressed_files:
-                    print(f"  ⊘ {f.split('/')[-1]} (already compressed)")
+                    print(f"  ⊘ {f.split('/')[-1]} (already processed)")
                     continue
                 if f in failed_files:
                     print(f"  ✗ {f.split('/')[-1]} (previously failed)")
@@ -398,7 +407,7 @@ async def scan_and_compress_videos():
 
 @app.on_event("startup")
 async def startup_event():
-    """Start compression scan on server startup with 30s delay."""
+    """Schedule compression scan on server startup with 30s delay."""
     print("\n" + "="*80)
     print("STARTUP EVENT TRIGGERED")
     print("="*80)
@@ -415,11 +424,14 @@ async def startup_event():
     except Exception as e:
         print(f"✗ Error checking ffmpeg: {e}")
     
-    # Wait 30 seconds before starting scan
-    print("\nWaiting 30 seconds before starting compression scan...")
-    await asyncio.sleep(30)
-    print("Starting compression scan now...")
-    await scan_and_compress_videos()
+    # Schedule scan as background task (don't wait for it)
+    async def delayed_scan():
+        print("\nWaiting 30 seconds before starting compression scan...")
+        await asyncio.sleep(30)
+        print("Starting compression scan now...")
+        await scan_and_compress_videos()
+    
+    asyncio.create_task(delayed_scan())
 
 
 @app.get("/")