danvics/haiku.rag
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Issue a full state snapshot from ask() tool to preserve server side background context

Browse source
This commit is contained in:
Yiorgis Gozadinos 2026-02-11 17:49:09 +02:00
parent 58c2bd49ea
commit 51f1d9cf13
No known key found for this signature in database
2 changed files with 11 additions and 34 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

13
haiku_rag_slim/haiku/rag/agents/chat/state.py
View file

@ -6,8 +6,6 @@ from pydantic import BaseModel
from haiku.rag.agents.research.models import Citation from haiku.rag.agents.research.models import Citation
if TYPE_CHECKING: if TYPE_CHECKING:
from ag_ui.core import StateDeltaEvent
from haiku.rag.tools.qa import QAHistoryEntry, QASessionState from haiku.rag.tools.qa import QAHistoryEntry, QASessionState
from haiku.rag.tools.session import SessionState from haiku.rag.tools.session import SessionState
@ -76,14 +74,3 @@ def build_chat_state_snapshot(
snapshot["session_context"] = None snapshot["session_context"] = None
return snapshot return snapshot
def build_chat_state_delta(
old_snapshot: dict[str, Any],
new_snapshot: dict[str, Any],
state_key: str | None,
) -> "StateDeltaEvent | None":
"""Compute a delta patch between two combined snapshots."""
from haiku.rag.tools.session import compute_combined_state_delta
return compute_combined_state_delta(old_snapshot, new_snapshot, state_key)

32
haiku_rag_slim/haiku/rag/tools/qa.py
View file

@ -1,13 +1,11 @@
import math import math
from ag_ui.core import EventType, StateSnapshotEvent
from pydantic import BaseModel, Field from pydantic import BaseModel, Field
from pydantic_ai import FunctionToolset, ToolReturn from pydantic_ai import FunctionToolset, ToolReturn
from haiku.rag.agents.chat.context import trigger_background_summarization from haiku.rag.agents.chat.context import trigger_background_summarization
from haiku.rag.agents.chat.state import ( from haiku.rag.agents.chat.state import build_chat_state_snapshot
build_chat_state_delta,
build_chat_state_snapshot,
)
from haiku.rag.agents.research.dependencies import ResearchContext from haiku.rag.agents.research.dependencies import ResearchContext
from haiku.rag.agents.research.graph import build_research_graph from haiku.rag.agents.research.graph import build_research_graph
from haiku.rag.agents.research.models import Citation, SearchAnswer from haiku.rag.agents.research.models import Citation, SearchAnswer
@ -258,7 +256,6 @@ def create_qa_toolset(
""" """
session_state: SessionState | None = None session_state: SessionState | None = None
qa_session_state: QASessionState | None = None qa_session_state: QASessionState | None = None
old_state_snapshot: dict | None = None
state_key: str | None = None state_key: str | None = None
if context is not None: if context is not None:
@ -266,12 +263,6 @@ def create_qa_toolset(
qa_session_state = context.get(QA_SESSION_NAMESPACE, QASessionState) qa_session_state = context.get(QA_SESSION_NAMESPACE, QASessionState)
state_key = context.state_key state_key = context.state_key
if session_state is not None:
old_state_snapshot = build_chat_state_snapshot(
session_state,
qa_session_state,
)
qa_result = await run_qa_core( qa_result = await run_qa_core(
client=client, client=client,
config=config, config=config,
@ -283,25 +274,24 @@ def create_qa_toolset(
prior_answers=prior_answers, prior_answers=prior_answers,
) )
if session_state is not None and old_state_snapshot is not None: if session_state is not None:
new_state_snapshot = build_chat_state_snapshot( snapshot = build_chat_state_snapshot(
session_state, session_state,
qa_session_state, qa_session_state,
) )
if state_key:
state_event = build_chat_state_delta( snapshot = {state_key: snapshot}
old_state_snapshot,
new_state_snapshot,
state_key=state_key,
)
answer_text = qa_result.answer answer_text = qa_result.answer
if qa_result.citations: if qa_result.citations:
citation_refs = " ".join(f"[{c.index}]" for c in qa_result.citations) citation_refs = " ".join(f"[{c.index}]" for c in qa_result.citations)
answer_text = f"{answer_text}\n\nSources: {citation_refs}" answer_text = f"{answer_text}\n\nSources: {citation_refs}"
metadata = [state_event] if state_event is not None else None state_event = StateSnapshotEvent(
return ToolReturn(return_value=answer_text, metadata=metadata) type=EventType.STATE_SNAPSHOT,
snapshot=snapshot,
)
return ToolReturn(return_value=answer_text, metadata=[state_event])
return qa_result return qa_result