Update app.py

app.py

@@ -129,8 +129,9 @@ async def handle_message(message: cl.Message):
             msg = cl.Message(content="")
             await msg.send()
 
+            qa_chain = cl.user_session.get("qa_chain")
             # Stream the response
-            async for chunk in rag_processor.generate_response(message.content):
+            async for chunk in qa_chain.astream(message.content):
                 await msg.stream_token(chunk)
         except Exception as e:
             await cl.Message(content=f"Error processing your message: {e}").send()