VertexAiSessionService: Event.id differs between the streamed event and getSession (id is not sent to Vertex and the appendEvent response is empty)
Mantenedores costumam responder em até 1 dia
Ninguém assumiu esta issue ainda.
Avaliação
- Dificuldade
- 4/5
- Tempo estimado
- 3-5 dias
- Facilidade para iniciantes
- 45/100
Direção de pesquisa
Start with VertexAiSessionService.appendEvent and SessionJsonConverter in com.google.adk.sessions, then compare event serialization with the Python fix linked in the issue. Check how the REST rawEvent field can preserve the ADK id and how session loading chooses an id. Done means the streamed event and the event returned by getSession retain the same id, with tests covering the round trip.
Escrita pelo modelo de indexação a partir do texto da issue.
Descrição
Describe the bug
With VertexAiSessionService, the same logical event has two different ids depending on how it is observed:
| Observed via | Event.id |
|---|---|
Runner.runAsync(...) stream |
ADK-generated UUID (Event.generateEventId()) |
getSession(...) afterwards |
Vertex resource id (last segment of the event name) |
InMemorySessionService keeps the ADK UUID, so the two services behave differently and the problem does not show up in local development.
Where (checked on 1.8.0 and 1.10.1)
BaseLlmFlowcreates the id withEvent.generateEventId()(a random UUID) and resets it for each resulting event.Runner.runAsynccallssessionService.appendEvent(session, event)for every non-partial event, then emits the event to the caller.VertexAiSessionService.appendEventsendsSessionJsonConverter.convertEventToJson(e)to:appendEvent. That JSON containsauthor,invocationId,timestamp,actions,eventMetadataandcontent, but no event id, and norawEvent(there is no reference torawEventanywhere incom.google.adk.sessionsin these versions).VertexAiClient.appendEventonly checks the response body forClientExceptionand returnsCompletable.complete().VertexAiSessionService.appendEventthen returns the local event (.toSingleDefault(e)), so the caller keeps the ADK UUID.- On
getSession,SessionJsonConverterrebuilds the id from the API resource name:
.id(Iterables.getLast(Splitter.on('/').split(apiEvent.get("name").toString())))
What the API allows
From the SessionEvent REST reference:
nameis documented as "Identifier. The resource name of the event" (…/sessions/{session}/events/{event}). There is no other field meant to carry a client-assigned event id.rawEventis "Optional. Weakly typed raw event data in proto struct format."sessions.appendEventreturns an empty body on success, so the id created by the service is not available at append time.
Documentation
The Events documentation says that the session service "records the event as it received it" (in the Python description) and recommends using event.id to reference specific occurrences. This does not hold for VertexAiSessionService: the id seen during the run is never stored and is replaced on reload.
Impact
Anything that correlates a streamed event with its persisted form by Event.id breaks. In our case (a chat UI built on top of an AG-UI endpoint), message ids sent to the client while streaming do not match the ids returned when the conversation is reloaded, so per-message state (for example feedback) can be attached to an id that no longer exists. The only workaround we found is to reload the session after the run and pair events by invocationId and order while checking the text, which is fragile.
Expected behavior
One of:
- Persist the ADK id (for example in
rawEvent, as ADK Python now does) and prefer it over the resource name when reading; or - Make the id assigned by Vertex available to the caller at append time (not possible today since the response is empty); or
- If neither is possible, document that
Event.idis not stable across streaming and reload on this service.
Related
- google/adk-python#6530: same behavior in Python, closed as a bug and fixed by keeping the id stored in
raw_event(commit 864914b). The Java converter does not writerawEvent, so that fix does not port directly. - google/adk-go#1329: same behavior in Go (open), noting that
SessionEventhas no field for a client event id.
Environment
google-adk1.8.0 (the same code is present in 1.10.1)VertexAiSessionServiceon Vertex AI Agent Engine sessions
- Linguagem predominante
- Java
- Estrelas
- 1.7k
- Forks
- 433
- Merge médio
- 2d 21h
- PRs com merge (30d)
- 43
Preparar o ambiente
Inicia o contêiner de desenvolvimento do projeto no navegador, com a sua própria conta do GitHub.
- Sem Dockerfile nem arquivo Docker Compose
- Tem um modelo de pull request
- Ler o guia de contribuição
Primeiros passos
- Leia a issue inteira e depois o guia de contribuição do projeto.
- Comente na issue dizendo que vai assumir — evita que duas pessoas façam o mesmo trabalho.
- Faça um fork do repositório e trabalhe em uma branch.
- Abra um pull request que referencie o número da issue.
Mais de google/adk-java
-
GeminiUtil placeholder user turn ("Continue output. DO NOT look at this line ...") is flagged by prompt injection filtersTalvez já em andamento @hemasekhar-p assumiu há 5 dias. Abertaneeds review
Dificuldade 2/5 1-3 horas Facilidade para iniciantes 76/100
google/adk-java#1628 · 1 comentário · 1 responsável ·
Mantenedores costumam responder em até 1 dia
-
[spring-ai] Streaming responses ending with CJK punctuation (。!?) are misclassified as partial and never persisted to the sessionTalvez já em andamento @hirematha assumiu há 8 dias. Abertaneeds review
Dificuldade 2/5 1-3 horas Facilidade para iniciantes 84/100
google/adk-java#1608 · 3 comentários · 1 responsável ·
Mantenedores costumam responder em até 1 dia
-
runLive passes partial events to appendEvent and never aggregates text chunks, unlike ADK PythonTalvez já em andamento @hemasekhar-p assumiu há 1 dia. Abertawaiting on reporter
Dificuldade 4/5 3-5 dias Facilidade para iniciantes 45/100
google/adk-java#1648 · 1 comentário · 1 responsável ·
Mantenedores costumam responder em até 1 dia
-
FirestoreSessionService compares event timestamps as text, reordering or skipping same-second eventsTalvez já em andamento @hemasekhar-p assumiu há 1 dia. Abertawaiting on reporter
Dificuldade 3/5 1-2 dias Facilidade para iniciantes 50/100
google/adk-java#1646 · 2 comentários · 1 responsável ·
Mantenedores costumam responder em até 1 dia
-
FirestoreSessionService ignores `app:` / `user:` state prefixes, so app and user state are never shared across sessionsTalvez já em andamento @hemasekhar-p assumiu há 1 dia. Abertawaiting on reporter
Dificuldade 4/5 3-5 dias Facilidade para iniciantes 45/100
google/adk-java#1645 · 2 comentários · 1 responsável ·
Mantenedores costumam responder em até 1 dia
Todas as issues de google/adk-java
Issues semelhantes
-
Flight SQL JDBC parses boolean properties case-sensitively, silently disabling TLS for useEncryption=TRUETalvez já em andamento @Arawoof06 assumiu hoje. Aberta
Dificuldade 2/5 1-3 horas Facilidade para iniciantes 79/100
apache/arrow-java#1357 ·
Mantenedores costumam responder em até 1 dia
-
Dificuldade 2/5 1-3 horas Facilidade para iniciantes 77/100
apache/rocketmq-dashboard#6610 ·
Mantenedores costumam responder em até 3 dias
-
Dificuldade 2/5 1-3 horas Facilidade para iniciantes 78/100
MetricsHub/metricshub-community#1396 ·
Mantenedores costumam responder em até 1 dia
-
L: java:gradle L: java:maven L: ruby:bundler T: bug 🐞
Dificuldade 2/5 1-3 horas Facilidade para iniciantes 76/100
dependabot/dependabot-core#16547 ·
Mantenedores costumam responder em até 1 dia
-
Citationcount column sorts alphabetically instead of numericallyTalvez já em andamento @kpunia306 assumiu hoje. Abertastatus: needs-triage
Dificuldade 2/5 1-3 horas Facilidade para iniciantes 68/100
JabRef/jabref#17459 · 4 comentários ·
Mantenedores costumam responder em até 1 dia