import (
"context"
"fmt"
- "log"
"maps"
"os"
"path/filepath"
summarizer.SetFailing(true)
logs := &SyncBuffer{}
- memory, err := openMemory(t.Context(), t.TempDir(), newTestClock().Now, summarizer, log.New(logs, "", 0))
+ memory, err := openMemory(t.Context(), t.TempDir(), newTestClock().Now, summarizer, daemonTestLogger(logs))
require.NoError(t, err)
defer func() {
_, err = memory.Append("echo", memoryLongText(0))
require.NoError(t, err)
require.ErrorIs(t, memory.Settle(t.Context()), errMemoryUnsettled)
- require.Equal(t, "summary failed, retry at next message: node (0, 0): fake failure\n", logs.String())
+ require.Equal(t, "<4>summary failed level=0 index=0: fake failure\n", logs.String())
summarizer.SetFailing(false)