Update app.py

app.py

@@ -130,7 +130,7 @@ async def main(message: cl.Message):
     chain = cl.user_session.get("chain")
 
     msg = cl.Message(content="")
-    result = await chain.arun_pipeline(message.content)
+    result = await chain.invoke({"question": message.content})
 
     async for stream_resp in result["response"]:
         await msg.stream_token(stream_resp)