Update core/visual_engine.py

core/visual_engine.py

@@ -470,7 +470,11 @@ class VisualEngine:
 
     # --- RunwayML Video Generation (Gen-4 Aligned with SDK) ---
     def _generate_video_clip_with_runwayml(
-        self, text_prompt_for_motion, input_image_path, scene_identifier_filename_base, target_duration_seconds=5
+        self,
+        text_prompt_for_motion,
+        input_image_path,
+        scene_identifier_filename_base,
+        target_duration_seconds=5,
     ):
         if not self.USE_RUNWAYML or not self.runway_ml_client_instance:
             logger.warning("RunwayML not enabled or client not initialized. Cannot generate video clip.")
@@ -589,8 +593,8 @@ class VisualEngine:
         # (Keeping as before)
         if size is None:
             size = self.video_frame_size
-            fp = os.path.join(self.output_dir, filename)
-            tc = None
+        fp = os.path.join(self.output_dir, filename)
+        tc = None
         try:
             tc = TextClip(
                 text_description,
@@ -781,6 +785,7 @@ class VisualEngine:
         try:
             logger.info(f"11L audio (Voice:{self.elevenlabs_voice_id}): {text_to_narrate[:70]}...")
             asm = None
+
             if hasattr(self.elevenlabs_client, "text_to_speech") and hasattr(
                 self.elevenlabs_client.text_to_speech, "stream"
             ):
@@ -799,31 +804,33 @@ class VisualEngine:
                 ab = self.elevenlabs_client.generate(
                     text=text_to_narrate, voice=vp, model="eleven_multilingual_v2"
                 )
-            with open(afp, "wb") as f:
-                f.write(ab)
-            logger.info(f"11L audio (non-stream): {afp}")
-            return afp
-        else:
-            logger.error("No 11L audio method.")
-            return None
+                with open(afp, "wb") as f:
+                    f.write(ab)
+                logger.info(f"11L audio (non-stream): {afp}")
+                return afp
+            else:
+                logger.error("No 11L audio method.")
+                return None
+
+            # If we have a streaming method (asm), use it
+            if asm:
+                vps = {"voice_id": str(self.elevenlabs_voice_id)}
+                if self.elevenlabs_voice_settings:
+                    if hasattr(self.elevenlabs_voice_settings, "model_dump"):
+                        vps["voice_settings"] = self.elevenlabs_voice_settings.model_dump()
+                    elif hasattr(self.elevenlabs_voice_settings, "dict"):
+                        vps["voice_settings"] = self.elevenlabs_voice_settings.dict()
+                    else:
+                        vps["voice_settings"] = self.elevenlabs_voice_settings
+
+                adi = asm(text=text_to_narrate, model_id="eleven_multilingual_v2", **vps)
+                with open(afp, "wb") as f:
+                    for c in adi:
+                        if c:
+                            f.write(c)
+                logger.info(f"11L audio (stream): {afp}")
+                return afp
 
-        if asm:
-            vps = {"voice_id": str(self.elevenlabs_voice_id)}
-            if self.elevenlabs_voice_settings:
-                if hasattr(self.elevenlabs_voice_settings, "model_dump"):
-                    vps["voice_settings"] = self.elevenlabs_voice_settings.model_dump()
-                elif hasattr(self.elevenlabs_voice_settings, "dict"):
-                    vps["voice_settings"] = self.elevenlabs_voice_settings.dict()
-                else:
-                    vps["voice_settings"] = self.elevenlabs_voice_settings
-
-            adi = asm(text=text_to_narrate, model_id="eleven_multilingual_v2", **vps)
-            with open(afp, "wb") as f:
-                for c in adi:
-                    if c:
-                        f.write(c)
-            logger.info(f"11L audio (stream): {afp}")
-            return afp
         except Exception as e:
             logger.error(f"11L audio error: {e}", exc_info=True)
             return None
@@ -1040,9 +1047,7 @@ class VisualEngine:
             return None
         finally:
             logger.debug("Closing all MoviePy clips in `assemble_animatic_from_assets` finally block.")
-            all_clips_to_close = processed_clips + (
-                [narration_clip] if narration_clip else []
-            ) + ([final_clip] if final_clip else [])
+            all_clips_to_close = processed_clips + ([narration_clip] if narration_clip else []) + ([final_clip] if final_clip else [])
             for clip_obj_to_close in all_clips_to_close:
                 if clip_obj_to_close and hasattr(clip_obj_to_close, "close"):
                     try: