Hey Team,
I am using arun with streaming
For some cases I need to stop the run of the Agent/Team
Code example:
async for event in await agent.arun(
message=session.last_user_message,
session_id=session_id,
user_id=user_id,
stream=True,
stream_intermediate_steps=True,
stream_member_events=True,
):
# specific use-case
break
Instead of just break, I wonder how can I save the current run to the session DB?
I want to make sure that I am saving the current state
Any suggestions?
Thank you!