capture before_run modifications and fix session history sync in runners.py

llms.txt

@@ -170,8 +170,8 @@ Happy Agent Building!
 - [Custom agents](https://github.com/google/adk-docs/blob/main/docs/agents/custom-agents.md)
 - [Agents](https://github.com/google/adk-docs/blob/main/docs/agents/index.md)
 - [LLM Agent](https://github.com/google/adk-docs/blob/main/docs/agents/llm-agents.md)
-- [Using Different Models with ADK](https://github.com/google/adk-docs/blob/main/docs/agents/models.md)
-- [Multi-Agent Systems in ADK](https://github.com/google/adk-docs/blob/main/docs/agents/multi-agents.md)
+- [Using Different Models with ADK](https://github.com/google/adk-docs/blob/main/docs/agents/models/index.md)
+- [Multi-Agent Systems in ADK](https://github.com/google/adk-docs/blob/main/docs/workflows/collaboration.md)
 - [Workflow Agents](https://github.com/google/adk-docs/blob/main/docs/agents/workflow-agents/index.md)
 - [Loop agents](https://github.com/google/adk-docs/blob/main/docs/agents/workflow-agents/loop-agents.md)
 - [Parallel agents](https://github.com/google/adk-docs/blob/main/docs/agents/workflow-agents/parallel-agents.md)
@@ -181,48 +181,44 @@ Happy Agent Building!
 - [Design Patterns and Best Practices for Callbacks](https://github.com/google/adk-docs/blob/main/docs/callbacks/design-patterns-and-best-practices.md)
 - [Callbacks: Observe, Customize, and Control Agent Behavior](https://github.com/google/adk-docs/blob/main/docs/callbacks/index.md)
 - [Types of Callbacks](https://github.com/google/adk-docs/blob/main/docs/callbacks/types-of-callbacks.md)
-- [Community Resources](https://github.com/google/adk-docs/blob/main/docs/community.md)
+- [Community Resources](https://github.com/google/adk-docs/blob/main/docs/community/index.md)
 - [Context](https://github.com/google/adk-docs/blob/main/docs/context/index.md)
-- [1. [`google/adk-python`](https://github.com/google/adk-python)](https://github.com/google/adk-docs/blob/main/docs/contributing-guide.md)
-- [Deploy to Vertex AI Agent Engine](https://github.com/google/adk-docs/blob/main/docs/deploy/agent-engine.md)
+- [Contributing Guide](https://github.com/google/adk-docs/blob/main/docs/community/contributing-guide.md)
+- [Deploying Your Agent](https://github.com/google/adk-docs/blob/main/docs/deploy/index.md)
+- [Deploy to Vertex AI Agent Engine](https://github.com/google/adk-docs/blob/main/docs/deploy/agent-runtime/index.md)
 - [Deploy to Cloud Run](https://github.com/google/adk-docs/blob/main/docs/deploy/cloud-run.md)
 - [Deploy to GKE](https://github.com/google/adk-docs/blob/main/docs/deploy/gke.md)
-- [Deploying Your Agent](https://github.com/google/adk-docs/blob/main/docs/deploy/index.md)
+- [Test deployed agents in Agent Runtime](https://github.com/google/adk-docs/blob/main/docs/deploy/agent-runtime/test.md)
 - [Why Evaluate Agents](https://github.com/google/adk-docs/blob/main/docs/evaluate/index.md)
 - [Events](https://github.com/google/adk-docs/blob/main/docs/events/index.md)
 - [Agent Development Kit (ADK)](https://github.com/google/adk-docs/blob/main/docs/get-started/about.md)
 - [Get Started](https://github.com/google/adk-docs/blob/main/docs/get-started/index.md)
 - [Installing ADK](https://github.com/google/adk-docs/blob/main/docs/get-started/installation.md)
-- [Quickstart](https://github.com/google/adk-docs/blob/main/docs/get-started/quickstart.md)
+- [Quickstart](https://github.com/google/adk-docs/blob/main/docs/get-started/python.md)
 - [Streaming Quickstarts](https://github.com/google/adk-docs/blob/main/docs/get-started/streaming/index.md)
 - [Quickstart (Streaming / Java) {#adk-streaming-quickstart-java}](https://github.com/google/adk-docs/blob/main/docs/get-started/streaming/quickstart-streaming-java.md)
 - [Quickstart (Streaming / Python) {#adk-streaming-quickstart}](https://github.com/google/adk-docs/blob/main/docs/get-started/streaming/quickstart-streaming.md)
-- [Testing your Agents](https://github.com/google/adk-docs/blob/main/docs/get-started/testing.md)
 - [What is Agent Development Kit?](https://github.com/google/adk-docs/blob/main/docs/index.md)
 - [Model Context Protocol (MCP)](https://github.com/google/adk-docs/blob/main/docs/mcp/index.md)
-- [Agent Observability with Arize AX](https://github.com/google/adk-docs/blob/main/docs/observability/arize-ax.md)
-- [Agent Observability with Phoenix](https://github.com/google/adk-docs/blob/main/docs/observability/phoenix.md)
+- [Agent Observability with Arize AX](https://github.com/google/adk-docs/blob/main/docs/integrations/arize-ax.md)
+- [Agent Observability with Phoenix](https://github.com/google/adk-docs/blob/main/docs/integrations/phoenix.md)
 - [Runtime](https://github.com/google/adk-docs/blob/main/docs/runtime/index.md)
 - [Runtime Configuration](https://github.com/google/adk-docs/blob/main/docs/runtime/runconfig.md)
 - [Safety & Security for AI Agents](https://github.com/google/adk-docs/blob/main/docs/safety/index.md)
 - [Introduction to Conversational Context: Session, State, and Memory](https://github.com/google/adk-docs/blob/main/docs/sessions/index.md)
 - [Memory: Long-Term Knowledge with `MemoryService`](https://github.com/google/adk-docs/blob/main/docs/sessions/memory.md)
-- [Session: Tracking Individual Conversations](https://github.com/google/adk-docs/blob/main/docs/sessions/session.md)
+- [Session: Tracking Individual Conversations](https://github.com/google/adk-docs/blob/main/docs/sessions/index.md)
 - [State: The Session's Scratchpad](https://github.com/google/adk-docs/blob/main/docs/sessions/state.md)
 - [Configurating streaming behaviour](https://github.com/google/adk-docs/blob/main/docs/streaming/configuration.md)
-- [Custom Audio Streaming app (WebSocket) {#custom-streaming-websocket}](https://github.com/google/adk-docs/blob/main/docs/streaming/custom-streaming-ws.md)
-- [Custom Audio Streaming app (SSE) {#custom-streaming}](https://github.com/google/adk-docs/blob/main/docs/streaming/custom-streaming.md)
 - [ADK Bidi-streaming development guide: Part 1 - Introduction](https://github.com/google/adk-docs/blob/main/docs/streaming/dev-guide/part1.md)
 - [Bidi-streaming(live) in ADK](https://github.com/google/adk-docs/blob/main/docs/streaming/index.md)
 - [Streaming Tools](https://github.com/google/adk-docs/blob/main/docs/streaming/streaming-tools.md)
-- [Authenticating with Tools](https://github.com/google/adk-docs/blob/main/docs/tools/authentication.md)
-- [Built-in tools](https://github.com/google/adk-docs/blob/main/docs/tools/built-in-tools.md)
-- [Function tools](https://github.com/google/adk-docs/blob/main/docs/tools/function-tools.md)
-- [Google Cloud Tools](https://github.com/google/adk-docs/blob/main/docs/tools/google-cloud-tools.md)
-- [Tools](https://github.com/google/adk-docs/blob/main/docs/tools/index.md)
-- [Model Context Protocol Tools](https://github.com/google/adk-docs/blob/main/docs/tools/mcp-tools.md)
-- [OpenAPI Integration](https://github.com/google/adk-docs/blob/main/docs/tools/openapi-tools.md)
-- [Third Party Tools](https://github.com/google/adk-docs/blob/main/docs/tools/third-party-tools.md)
+- [Authenticating with Tools](https://github.com/google/adk-docs/blob/main/docs/tools-custom/authentication.md)
+- [Built-in tools](https://github.com/google/adk-docs/blob/main/docs/integrations/index.md)
+- [Function tools](https://github.com/google/adk-docs/blob/main/docs/tools-custom/function-tools.md)
+- [Tools](https://github.com/google/adk-docs/blob/main/docs/tools-custom/index.md)
+- [Model Context Protocol Tools](https://github.com/google/adk-docs/blob/main/docs/tools-custom/mcp-tools.md)
+- [OpenAPI Integration](https://github.com/google/adk-docs/blob/main/docs/tools-custom/openapi-tools.md)
 - [Build Your First Intelligent Agent Team: A Progressive Weather Bot with ADK](https://github.com/google/adk-docs/blob/main/docs/tutorials/agent-team.md)
 - [ADK Tutorials!](https://github.com/google/adk-docs/blob/main/docs/tutorials/index.md)
-- [Python API Reference](https://github.com/google/adk-docs/blob/main/docs/api-reference/python/)
+- [API Reference](https://github.com/google/adk-docs/blob/main/docs/api-reference/index.md)

src/google/adk/runners.py

@@ -528,7 +528,18 @@ async def _run_node_async(
           yield user_event
 
       # Run before_run callbacks
-      await ic.plugin_manager.run_before_run_callback(invocation_context=ic)
+      corrected_user_message = await ic.plugin_manager.run_before_run_callback(invocation_context=ic)
+      if corrected_user_message is not None:
+        if isinstance(corrected_user_message, types.Content):
+          node_input = corrected_user_message
+          ic.user_content = corrected_user_message
+          if hasattr(ic.session, 'events') and len(ic.session.events) > 0:
+              ic.session.events.pop()
+          user_event = await self._append_user_event(
+              ic, corrected_user_message
+          )
+          if yield_user_message and user_event:
+            yield user_event
 
       # 3. Start root node in background
       from .agents.base_agent import BaseAgent