}
func TestMemoryFlushSyncsTheChat(t *testing.T) {
- memory, err := openMemory(t.Context(), t.TempDir(), newTestClock().Now, newFakeSummarizer())
+ memory, err := openMemory(t.Context(), t.TempDir(), newTestClock().Now, newFakeSummarizer(), discardLog())
require.NoError(t, err)
_, err = memory.Append("tool", "shell: ls")
for round := range 3 {
acknowledged := syncerRunKilledWriter(t, root, 200+100*round)
- memory, err := openMemory(t.Context(), root, time.Now, newFakeSummarizer())
+ memory, err := openMemory(t.Context(), root, time.Now, newFakeSummarizer(), discardLog())
require.NoError(t, err)
require.GreaterOrEqual(t, memory.log.Len(), acknowledged)
for id := range memory.log.Len() {
t.Skip("runs only as a child process")
}
- memory, err := openMemory(t.Context(), root, time.Now, newFakeSummarizer())
+ memory, err := openMemory(t.Context(), root, time.Now, newFakeSummarizer(), discardLog())
require.NoError(t, err)
for id := memory.log.Len(); ; id++ {