Function _writeLedger

src/atp/atpTaskPickup.js:63–79

(ledger)

}

function _writeLedger(ledger) {
  try {
    const dir = getMemoryDir();
    if (!fs.existsSync(dir)) fs.mkdirSync(dir, { recursive: true });
    const entries = Object.entries(ledger.spawned || {});
    if (entries.length > LEDGER_MAX_ENTRIES) {
      ledger.spawned = Object.fromEntries(entries.slice(-LEDGER_MAX_ENTRIES));
    }
    const tmp = _ledgerPath() + '.tmp';
    fs.writeFileSync(tmp, JSON.stringify(ledger, null, 2));
    fs.renameSync(tmp, _ledgerPath());
  } catch (_) {
    // Non-fatal: next tick will re-read Hub state. Stale ledger at worst
    // causes a duplicate spawn, which the Hub will 409 on already-completed
    // tasks without side effects.
  }
}

function _isEligible(task) {
  if (!task || typeof task !== 'object') return false;