}
client := newModelClient(address, auth, agent.CacheKey(), filepath.Join(agent.dir, "usage.jsonl"))
- memory, err := openMemory(ctx, agent.dir, time.Now, newCompactor(client, agent.Prompt, config.Compactor))
+ memory, err := openMemory(ctx, agent.dir, time.Now, newCompactor(client, agent.Prompt, config.Compactor), logger)
if err != nil {
return err
}
err = errors.Join(err, memory.Close())
}()
- schedules, err := openSchedules(filepath.Join(agent.dir, scheduleFileName), time.Now)
+ schedules, err := openSchedules(filepath.Join(agent.dir, scheduleFileName), time.Now, logger)
if err != nil {
return err
}
}
return daemonServe(ctx, listener, telegram, whatsapp, schedules, func(notify func(Event)) (*TurnLoop, error) {
- return newTurnLoop(agent, memory, subagents, whatsapp, schedules, client, time.Now, notify)
+ return newTurnLoop(agent, memory, subagents, whatsapp, schedules, client, time.Now, logger, notify)
})
}