(state *AgentState, sources map[string]struct{})
| 1342 | cfg := e.Config |
| 1343 | cfg.SessionMemoryAgentID = e.sessionMemoryAgentID() |
| 1344 | if err := e.sessionMemory.Observe(ctx, cfg, e.SessionID, state.Messages, force); err != nil { |
| 1345 | slog.Warn("session memory observe failed", "session_id", e.SessionID, "error", err) |
| 1346 | } |
| 1347 | if e.StateObserver != nil { |
| 1348 | e.StateObserver(state) |
| 1349 | } |
| 1350 | } |
| 1351 | |
| 1352 | func (e *CoreExecutionEngine) sessionMemoryAgentID() string { |
no test coverage detected