Function runOne

src/schedule/runner.ts:82–174

(entry: ScheduleEntry)

}

async function runOne(entry: ScheduleEntry): Promise<void> {
  const store = getScheduleStore();
  const startMs = Date.now();
  const runId = store.recordRunStart(entry.id);
  const logPath = path.join(RUN_LOG_DIR, `${entry.id}.${runId}.log`);
  const logStream = fsSync.createWriteStream(logPath, { flags: 'w' });
  logStream.write(`# schedule: ${entry.name} (${entry.id})\n# cron:     ${entry.cron}\n# cwd:      ${entry.cwd}\n# started:  ${new Date().toISOString()}\n# prompt:   ${entry.prompt.replace(/\n/g, '\n#           ')}\n\n`);

  // cwd must exist; otherwise mark errored and bail (no point retrying every minute)
  try {
    const st = fsSync.statSync(entry.cwd);
    if (!st.isDirectory()) throw new Error(`not a directory`);
  } catch (e: any) {
    const msg = `cwd invalid: ${entry.cwd} (${e.message})`;
    logStream.end(msg + '\n');
    store.recordRunFinish(runId, entry.id, 'error', 1, msg, Date.now() - startMs);
    return;
  }

  // Build child args: qodex --print <prompt> --yes [--model ...]
  // We use --yes so permission prompts auto-approve; without it the headless run
  // would deny everything and the schedule would be useless. A recipe (e.g. verified-pr)
  // wraps the goal in an unattended-safe protocol before it's fed to the agent.
  const runPrompt = buildRecipePrompt(entry.recipe, entry.prompt);
  const args: string[] = ['--print', runPrompt, '--yes'];
  if (entry.model) { args.push('--model', entry.model); }

  // Resolve the qodex CLI path. In production the user runs `npm link` so `qodex`
  // is on PATH; in dev we may need to point at bin/qodex.mjs directly.
  const cliPath = resolveCliPath();

  // Ask the child to write a ground-truth receipt here (built by QodeX from the git diff +
  // the checkers it ran, not the model). We prefer it over parsing the model's stdout block.
  const receiptFile = path.join(RUN_LOG_DIR, `${entry.id}.${runId}.receipt.json`);

  return new Promise<void>((resolve) => {
    const child = spawn(cliPath, args, {
      cwd: entry.cwd,
      env: { ...process.env, QODEX_SCHEDULED: '1', QODEX_RECEIPT_FILE: receiptFile },
      stdio: ['ignore', 'pipe', 'pipe'],
    });

    let output = '';
    child.stdout?.on('data', (d: Buffer) => { const s = d.toString(); output += s; logStream.write(s); });
    child.stderr?.on('data', (d: Buffer) => { const s = d.toString(); output += s; logStream.write(s); });

    const hardKill = setTimeout(() => {
      try { child.kill('SIGKILL'); } catch {}
    }, 30 * 60 * 1000); // 30 minute hard cap

    child.on('error', (e: any) => {
      clearTimeout(hardKill);
      const msg = `spawn failed: ${e.message}`;
      logStream.end('\n' + msg + '\n');
      store.recordRunFinish(runId, entry.id, 'error', 127, msg, Date.now() - startMs);
      resolve();
    });