(message: cl.Message)
| 47 | |
| 48 | @cl.on_message |
| 49 | async def main(message: cl.Message): |
| 50 | answer = cl.Message(content="") |
| 51 | await answer.send() |
| 52 | |
| 53 | config: RunnableConfig = { |
| 54 | "configurable": {"thread_id": cl.context.session.thread_id} |
| 55 | } |
| 56 | |
| 57 | for msg, _ in app.stream( |
| 58 | {"messages": [HumanMessage(content=message.content)]}, |
| 59 | config, |
| 60 | stream_mode="messages", |
| 61 | ): |
| 62 | if isinstance(msg, AIMessageChunk): |
| 63 | answer.content += msg.content # type: ignore |
| 64 | await answer.update() |