Update main.py

main.py

@@ -707,8 +707,8 @@ async def construction_NCS(romeListArray):
     #completion_NCS = chain.invoke({"question":question_p,"context":context_p})
 
     msg = cl.Message(author="Datapcc : 🌐🌐🌐",content="")
-    for chunk in chain.stream({"question":question_p,"context":context_p}):
-        msg.stream_token(chunk)
+    async for chunk in chain.astream({"question":question_p,"context":context_p}):
+        await msg.stream_token(chunk)
             
     #for s in chain.stream({"question":question_p,"context":context_p}):
     #  print(s, end="", flush=True)