Update app.py

app.py

@@ -67,25 +67,23 @@ def generate_feedback(user_id, question_choice, strategy_choice, message, feedba
     return feedback
 
 @spaces.GPU(duration=60)
-async def generate_audio_feedback(feedback_buffer):
+def generate_audio_feedback(feedback_buffer):
     communicate = edge_tts.Communicate(feedback_buffer)
     with tempfile.NamedTemporaryFile(delete=False, suffix=".wav") as tmp_file:
         tmp_path = tmp_file.name
-        await communicate.save(tmp_path)
+        asyncio.run(communicate.save(tmp_path))
     return tmp_path
 
-async def predict(question_choice, strategy_choice, feedback_level, audio):
+def predict(question_choice, strategy_choice, feedback_level, audio):
     current_audio_output = None
 
     if audio is None:
-        yield [("Oral Coach ⚡ϞϞ(๑⚈ ․̫ ⚈๑)∩ ⚡", "No audio data received. Please try again.")], current_audio_output
-        return
+        return [("Oral Coach ⚡ϞϞ(๑⚈ ․̫ ⚈๑)∩ ⚡", "No audio data received. Please try again.")], current_audio_output
 
     sample_rate, audio_data = audio
 
     if audio_data is None or len(audio_data) == 0:
-        yield [("Oral Coach ⚡ϞϞ(๑⚈ ․̫ ⚈๑)∩ ⚡", "No audio data received. Please try again.")], current_audio_output
-        return
+        return [("Oral Coach ⚡ϞϞ(๑⚈ ․̫ ⚈๑)∩ ⚡", "No audio data received. Please try again.")], current_audio_output
 
     audio_path = "audio.wav"
     if not isinstance(audio_data, np.ndarray):
@@ -93,37 +91,29 @@ async def predict(question_choice, strategy_choice, feedback_level, audio):
     sf.write(audio_path, audio_data, sample_rate)
 
     chat_history = [("Oral Coach ⚡ϞϞ(๑⚈ ․̫ ⚈๑)∩ ⚡", "Transcribing your audio, please listen to your oral response while waiting ...")]
-    yield chat_history, current_audio_output
 
     try:
-        transcription_future = executor.submit(transcribe, audio_path)
-        student_response = await asyncio.wrap_future(transcription_future)
+        student_response = transcribe(audio_path)
 
         if not student_response.strip():
-            yield [("Oral Coach ⚡ϞϞ(๑⚈ ․̫ ⚈๑)∩ ⚡", "Transcription failed. Please try again or seek assistance.")], current_audio_output
-            return
+            return [("Oral Coach ⚡ϞϞ(๑⚈ ․̫ ⚈๑)∩ ⚡", "Transcription failed. Please try again or seek assistance.")], current_audio_output
 
         chat_history.append(("Student", student_response))
-        yield chat_history, current_audio_output
 
         chat_history.append(("Oral Coach ⚡ϞϞ(๑⚈ ․̫ ⚈๑)∩ ⚡", "Transcription complete. Generating feedback. Please continue listening to your oral response while waiting ..."))
-        yield chat_history, current_audio_output
 
-        feedback_future = executor.submit(generate_feedback, int(user_state.value), question_choice, strategy_choice, student_response, feedback_level)
-        feedback = await asyncio.wrap_future(feedback_future)
+        feedback = generate_feedback(int(user_state.value), question_choice, strategy_choice, student_response, feedback_level)
 
         chat_history.append(("Oral Coach ⚡ϞϞ(๑⚈ ․̫ ⚈๑)∩ ⚡", feedback))
-        yield chat_history, current_audio_output
 
-        audio_future = executor.submit(generate_audio_feedback, feedback)
-        audio_output_path = await asyncio.wrap_future(audio_future)
+        audio_output_path = generate_audio_feedback(feedback)
 
         current_audio_output = (24000, audio_output_path)
-        yield chat_history, current_audio_output
+        return chat_history, current_audio_output
 
     except Exception as e:
         logging.error(f"An error occurred: {str(e)}", exc_info=True)
-        yield [("Oral Coach ⚡ϞϞ(๑⚈ ․̫ ⚈๑)∩ ⚡", "An error occurred. Please try again or seek assistance.")], current_audio_output
+        return [("Oral Coach ⚡ϞϞ(๑⚈ ․̫ ⚈๑)∩ ⚡", "An error occurred. Please try again or seek assistance.")], current_audio_output
 
 # Modify the toggle_oral_coach_visibility function to call add_user_privacy and store the returned user_id in user_state.value
 def toggle_oral_coach_visibility(class_name, index_no, policy_checked):