Spaces:
Runtime error
Runtime error
Commit
·
fe85ba7
1
Parent(s):
7ae1843
fix async error
Browse files
app.py
CHANGED
|
@@ -215,10 +215,12 @@ async def main(message: cl.Message):
|
|
| 215 |
|
| 216 |
msg = cl.Message(content="")
|
| 217 |
|
| 218 |
-
|
| 219 |
{"query": message.content},
|
| 220 |
config=RunnableConfig(callbacks=[cl.LangchainCallbackHandler()]),
|
| 221 |
-
)
|
|
|
|
|
|
|
| 222 |
await msg.stream_token(chunk)
|
| 223 |
|
| 224 |
await msg.send()
|
|
|
|
| 215 |
|
| 216 |
msg = cl.Message(content="")
|
| 217 |
|
| 218 |
+
chunks = await cl.make_async(lcel_rag_chain.stream)(
|
| 219 |
{"query": message.content},
|
| 220 |
config=RunnableConfig(callbacks=[cl.LangchainCallbackHandler()]),
|
| 221 |
+
)
|
| 222 |
+
|
| 223 |
+
async for chunk in chunks:
|
| 224 |
await msg.stream_token(chunk)
|
| 225 |
|
| 226 |
await msg.send()
|