Replies: 3 comments 1 reply
-
|
@DeanChensj can you please help with this query. |
Beta Was this translation helpful? Give feedback.
-
|
Hi @strentom , the session is persisted at event level. The runner will explicitly persist the event by calling |
Beta Was this translation helpful? Give feedback.
-
|
Hello @DeanChensj , can you please clarify?
It's actually unlikely this would be a user message in a complex system, right? Consider my example again, with more detail: class CustomAgent(BaseAgent):
@override
async def _run_async_impl(self, ctx: InvocationContext) -> AsyncGenerator[Event, None]:
async for event in self.subagent.run_async(ctx):
await long_function() # takes a minute to return
yield eventIn case execution is interrupted in |
Beta Was this translation helpful? Give feedback.
-
|
Let's say the agent entered the for loop of Note that the runner won't auto-restart, when the next query comes in, the agent will see previous chat history + [event1, event2] + new query, and start from there. |
Beta Was this translation helpful? Give feedback.
Uh oh!
There was an error while loading. Please reload this page.
-
Hello, I looked at source and in Docs, but couldn't find a definite answer. I'm looking at the Session Lifecycle. Is the session restored from last
Eventor User message? I'd think Event but the docs suggest from user Message? Or last "finished" event? Can you clarify which one?Consider this scenario:
I'm using
VertexAIServiceSessionfor persistence. I have a complex custom agent. The agent sends multipleassistantmsgs before the next user msg. It has following code:For the sake of the argument,
long_functiontakes a minute to finish and produces noEvents.What happens if the application is restarted while Code execution is happening in
long_function? Is the session restored from last user message? Or from last Yielded event? If from Event, is this event re-processed (that is,long_functionis executed twice)? Thank you very much.Beta Was this translation helpful? Give feedback.
All reactions