Update app.py

app.py

@@ -184,15 +184,18 @@ def handle_message(data):
     session_id = data.get('session_id', SESSION_ID_DEFAULT)
     chain = conversational_rag_chain.pick("answer")
 
-    try:
-        for chunk in chain.stream(
-                {"input": question, 'language': language},
-                config={"configurable": {"session_id": session_id}},
-            ):
-            emit('response', chunk, room=request.sid)
-    except Exception as e:
-        print(f"Error during message handling: {e}")
-        emit('response', {"error": "An error occurred while processing your request."+ str(e)}, room=request.sid)
+    for chunk in chain.stream({"input": question, 'language': language}, config={"configurable": {"session_id": session_id}}):
+        emit('response', chunk, room=request.sid)
+
+    # try:
+    #     for chunk in chain.stream(
+    #             {"input": question, 'language': language},
+    #             config={"configurable": {"session_id": session_id}},
+    #         ):
+    #         emit('response', chunk, room=request.sid)
+    # except Exception as e:
+    #     print(f"Error during message handling: {e}")
+    #     emit('response', {"error": "An error occurred while processing your request."+ str(e)}, room=request.sid)
 
 
 # Home route