Upload myinfer_latest.py

myinfer_latest.py

@@ -197,7 +197,10 @@ def api_convert_voice():
         p.join()
         print("*******waiting for process to complete ")
         output_path = output_queue.get()
-        print("output path of converted voice",output_path)
+        if isinstance(output_path, Exception):
+            print("Exception in worker:", output_path)
+        else:
+            print("output path of converted voice", output_path)
         #output_path = convert_voice(spk_id, vocal_path, voice_transform,unique_id)
         output_path1= combine_vocal_and_inst(output_path,inst,unique_id)
         
@@ -239,14 +242,13 @@ def get_processed_audio(audio_id):
     return jsonify({"error": "File not found."}), 404
 
 def worker(spk_id, input_audio_path, voice_transform, unique_id, output_queue):
-    """
-    Worker function to be executed in a separate process.
-    """
-    # Call the convert_voice function
-    output_audio_path = convert_voice(spk_id, input_audio_path, voice_transform, unique_id)
-    print("output in worker for audio file",output_audio_path)
-    # Put the result in the queue to be retrieved by the main process
-    output_queue.put(output_audio_path)
+    try:
+        output_audio_path = convert_voice(spk_id, input_audio_path, voice_transform, unique_id)
+        print("output in worker for audio file", output_audio_path)
+        output_queue.put(output_audio_path)
+    except Exception as e:
+        output_queue.put(e)  # Send the exception to the main process for debugging
+
 def convert_voice(spk_id, input_audio_path, voice_transform,unique_id):
     get_vc(spk_id,0.5)
     print("*****before makinf call to vc ", unique_id)