Update main.py

main.py

@@ -710,6 +710,33 @@ async def process_video_task(
         logger.exception(f"process_video_task unhandled for {job_id}")
         update_job(job_id, status="failed", error="Unexpected server error")
 
+async def _cleanup_old_videos():
+    """Deletes videos older than 1 hour every 10 minutes"""
+    while True:
+        await asyncio.sleep(600)  # 10 minutes
+        
+        try:
+            cutoff_time = time.time() - 3600  # 1 hour ago
+            cleaned_count = 0
+            cleaned_size_mb = 0.0
+            
+            for video_file in OUTPUT_DIR.glob("*.mp4"):
+                try:
+                    file_stat = video_file.stat()
+                    if file_stat.st_mtime < cutoff_time:
+                        file_size_mb = file_stat.st_size / 1024 / 1024
+                        video_file.unlink()
+                        cleaned_count += 1
+                        cleaned_size_mb += file_size_mb
+                        logger.info(f"Cleaned up {video_file.name} ({file_size_mb:.1f}MB)")
+                except Exception as e:
+                    logger.warning(f"Cleanup failed {video_file.name}: {e}")
+            
+            if cleaned_count > 0:
+                logger.info(f"Cleaned {cleaned_count} videos, freed {cleaned_size_mb:.1f}MB")
+        except Exception as e:
+            logger.error(f"Cleanup error: {e}")
+
 # =============================================================================
 # FILE CLEANUP HELPER
 # =============================================================================
@@ -1073,6 +1100,7 @@ async def startup():
     logger.info("=" * 60)
 
     asyncio.create_task(_queue_worker())
+    asyncio.create_task(_cleanup_old_videos())  
 
     try:
         vids = await list_videos_from_dataset("minecraft")