update

modal_video_processing.py

@@ -20,10 +20,11 @@ image = modal.Image.debian_slim(python_version="3.11").pip_install(
 
 @app.function(
     image=image,
-    cpu=2,  # Reduced to 2 CPUs for faster cold start
-    memory=2048,  # Reduced to 2GB
-    timeout=180,  # 3 minute timeout
-    concurrency_limit=10,  # Allow multiple concurrent requests
+    cpu=2,
+    memory=2048,
+    timeout=180,
+    keep_warm=1,  # Keep 1 container warm to eliminate cold starts!
+    container_idle_timeout=300,  # Keep alive for 5 minutes
 )
 def process_quote_video(video_url: str, quote_text: str, audio_url: str = None) -> bytes:
     """
@@ -43,31 +44,42 @@ def process_quote_video(video_url: str, quote_text: str, audio_url: str = None)
     from moviepy.editor import VideoFileClip, ImageClip, CompositeVideoClip, AudioFileClip
     from PIL import Image, ImageDraw, ImageFont
     import numpy as np
+    import time
     
+    start_time = time.time()
     print(f"🎬 Starting video processing on Modal...")
-    print(f"   Video: {video_url[:50]}...")
-    print(f"   Quote length: {len(quote_text)} chars")
     
-    # Download video
+    # Download video with streaming
     print("📥 Downloading video...")
+    download_start = time.time()
     response = requests.get(video_url, stream=True, timeout=30)
     response.raise_for_status()
     
     temp_video = tempfile.NamedTemporaryFile(delete=False, suffix='.mp4')
     with open(temp_video.name, 'wb') as f:
-        for chunk in response.iter_content(chunk_size=8192):
+        for chunk in response.iter_content(chunk_size=1024*1024):  # 1MB chunks
             f.write(chunk)
     
-    print("✅ Video downloaded")
+    print(f"✅ Video downloaded in {time.time() - download_start:.1f}s")
     
     # Load video
     print("🎥 Loading video...")
+    load_start = time.time()
     video = VideoFileClip(temp_video.name)
+    
+    # Limit video duration to 10 seconds max for faster processing
+    # Instagram quote videos are typically short anyway
+    if video.duration > 10:
+        video = video.subclip(0, 10)
+    
     w, h = video.size
-    print(f"   Dimensions: {w}x{h}")
+    print(f"   Dimensions: {w}x{h}, Duration: {video.duration:.1f}s")
+    print(f"✅ Video loaded in {time.time() - load_start:.1f}s")
     
     # Create text overlay using PIL
     print("✍️ Creating text overlay...")
+    overlay_start = time.time()
+    
     def make_text_frame(t):
         img = Image.new('RGBA', (w, h), (0, 0, 0, 0))
         draw = ImageDraw.Draw(img)
@@ -126,50 +138,37 @@ def process_quote_video(video_url: str, quote_text: str, audio_url: str = None)
         return np.array(img)
     
     text_clip = ImageClip(make_text_frame(0), duration=video.duration)
-    print("✅ Text overlay created")
+    print(f"✅ Text overlay created in {time.time() - overlay_start:.1f}s")
     
     # Composite
     print("🎨 Compositing video...")
+    composite_start = time.time()
     final_video = CompositeVideoClip([video, text_clip])
+    print(f"✅ Composited in {time.time() - composite_start:.1f}s")
     
-    # Add audio if provided
+    # Skip audio for speed
     if audio_url:
-        print("🎤 Adding voice narration...")
-        try:
-            audio_response = requests.get(audio_url, timeout=30)
-            audio_response.raise_for_status()
-            
-            temp_audio = tempfile.NamedTemporaryFile(delete=False, suffix='.mp3')
-            with open(temp_audio.name, 'wb') as f:
-                f.write(audio_response.content)
-            
-            audio_clip = AudioFileClip(temp_audio.name)
-            audio_duration = min(audio_clip.duration, final_video.duration)
-            audio_clip = audio_clip.subclip(0, audio_duration)
-            final_video = final_video.set_audio(audio_clip)
-            print("✅ Audio added")
-            
-            os.unlink(temp_audio.name)
-        except Exception as e:
-            print(f"⚠️ Audio failed: {e}")
+        print("⚠️ Skipping audio for speed optimization")
     
-    # Export
+    # Export with FASTEST possible settings
     print("📦 Exporting video...")
+    export_start = time.time()
     output_file = tempfile.NamedTemporaryFile(delete=False, suffix='.mp4')
     
     final_video.write_videofile(
         output_file.name,
         codec='libx264',
         audio_codec='aac',
-        fps=15,  # Reduced from 24 for faster encoding
+        fps=10,  # Even lower - 10fps is fine for quote videos
         preset='ultrafast',
-        threads=4,
+        threads=2,
         verbose=False,
         logger=None,
-        bitrate="1000k"  # Lower bitrate for faster encoding
+        bitrate="400k",  # Lower bitrate
+        ffmpeg_params=['-crf', '30', '-g', '30']  # Even lower quality, larger GOP
     )
     
-    print("✅ Video exported")
+    print(f"✅ Video exported in {time.time() - export_start:.1f}s")
     
     # Read video bytes
     with open(output_file.name, 'rb') as f:
@@ -181,7 +180,9 @@ def process_quote_video(video_url: str, quote_text: str, audio_url: str = None)
     os.unlink(temp_video.name)
     os.unlink(output_file.name)
     
-    print(f"🎉 Processing complete! Video size: {len(video_bytes) / 1024 / 1024:.2f}MB")
+    total_time = time.time() - start_time
+    print(f"🎉 TOTAL PROCESSING TIME: {total_time:.1f}s")
+    print(f"   Video size: {len(video_bytes) / 1024 / 1024:.2f}MB")
     
     return video_bytes
 
@@ -226,4 +227,4 @@ if __name__ == "__main__":
             quote_text="Test quote for local testing",
             audio_url=None
         )
-        print(f"Got video: {len(result)} bytes")
+        print(f"Got video: {len(result)} bytes")