Update main.py

main.py

@@ -65,9 +65,12 @@ async def on_message(message: cl.Message):
     
     msg = cl.Message(content="")
     
-    cb = cl.AsyncLangchainCallbackHandler()
+    #cb = cl.AsyncLangchainCallbackHandler()
+    async for chunk in agent.astream(message.content,
+                config=RunnableConfig(callbacks=[cl.AsyncLangchainCallbackHandler(stream_final_answer=True)])):
+            await msg.stream_token(chunk)
     #res = await agent.acall("Réponds en langue française à la question suivante :\n" + message.content + "\nDétaille la réponse en faisant une analyse complète en 2000 mots minimum.", callbacks=[cb])
     #res = await agent.ainvoke("D'après les informations fournies, réponds en langue française à la question suivante :\n" + message.content + "\nDétaille la réponse en faisant une analyse complète jusqu'à 2000 mots, si cela est nécessaire.")
-    answer = res['output']
+    #answer = res['output']
 
-    await cl.Message(content=GoogleTranslator(source='auto', target='fr').translate(answer)).send()
+    #await cl.Message(content=GoogleTranslator(source='auto', target='fr').translate(answer)).send()