Method constructor

packages/agent-core/src/agent/cron/manager.ts:143–182

(agent: Agent, opts: CronManagerOptions = {})

  private readonly persistQueues: Map<string, Promise<void>> = new Map();

  constructor(agent: Agent, opts: CronManagerOptions = {}) {
    this.agent = agent;
    this.store = new SessionCronStore();
    this.clocks =
      opts.clocks ??
      resolveClockSources(process.env['KIMI_CRON_CLOCK']) ??
      SYSTEM_CLOCKS;
    this.persistStore =
      agent.homedir === undefined
        ? undefined
        : createCronPersistStore(agent.homedir);

    this.scheduler = createCronScheduler({
      clocks: this.clocks,
      source: () => this.store.list(),
      isIdle: () => !agent.turn.hasActiveTurn,
      isKilled: () => process.env['KIMI_DISABLE_CRON'] === '1',
      onFire: (task, ctx) => {
        this.handleFire(task, ctx);
      },
      removeOneShot: (id) => {
        this.removeTasks([id]);
      },
      onAdvanceCursor: (id, lastFiredAt) => {
        this.advanceCursor(id, lastFiredAt);
      },
      // P1.8: `KIMI_CRON_MANUAL_TICK=1` forces the scheduler into
      // manual-drive mode (no setInterval), so bench / time-injected
      // tests can step time forward and call `tick()` explicitly without
      // racing a 1-second auto-tick. Explicit caller overrides
      // (`opts.pollIntervalMs`) lose to the env so a bench can flip the
      // switch from the outside without rebuilding the manager wiring.
      pollIntervalMs:
        process.env['KIMI_CRON_MANUAL_TICK'] === '1'
          ? null
          : opts.pollIntervalMs,
    });

    this.start();
  }

  /**
   * Add a fresh task to the in-memory store and, when persistence is