Update app_parallel.py

app_parallel.py

@@ -8,34 +8,33 @@ import asyncio
 
 async def convert_tts(model_name, tts_text, selected_voice, slang_rate, use_uploaded_voice, voice_upload):
     try:
+        print(f"Starting TTS for text: {tts_text[:50]}...")  # Log the start of processing
+        
         edge_tts_voice = voice_mapping.get(selected_voice)
         if not edge_tts_voice:
+            print(f"Invalid voice selected: {selected_voice}")
             return {"error": f"Invalid voice '{selected_voice}'."}, None
 
         voice_upload_file = None
         if use_uploaded_voice and voice_upload is not None:
+            print("Processing uploaded voice file...")
             with open(voice_upload.name, 'rb') as f:
                 voice_upload_file = f.read()
 
+        print("Calling TTS function...")
         info, edge_output_filename, tts_output_data = await asyncio.wait_for(
             tts(model_name, tts_text, edge_tts_voice, slang_rate, use_uploaded_voice, voice_upload_file),
-            timeout=60  # Adjust timeout as needed
+            timeout=60
         )
+        print("TTS function call completed.")
 
         if isinstance(info, dict) and "error" in info:
+            print(f"Error returned from TTS function: {info['error']}")
             return info, None
 
+        print("Processing TTS output...")
         tgt_sr, audio_output = tts_output_data
 
-        audio_bytes = None
-        if isinstance(audio_output, np.ndarray):
-            byte_io = BytesIO()
-            wavfile.write(byte_io, tgt_sr, audio_output.astype(np.int16))
-            byte_io.seek(0)
-            audio_bytes = byte_io.getvalue()
-        else:
-            audio_bytes = audio_output
-
         # Clean up the temporary EdgeTTS output file if it exists
         if edge_output_filename and os.path.exists(edge_output_filename):
             os.remove(edge_output_filename)