singularity/singularity-forge
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

fix: make skip-loop interruptible and count toward lifetime cap (#792)

Browse source 
Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>
This commit is contained in:
Lex Christopherson 2026-03-16 22:27:39 -06:00
parent ad4e68551d
commit 22f623889f
1 changed files with 30 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

34
src/resources/extensions/gsd/auto.ts
View file

@ -2426,18 +2426,31 @@ async function dispatchNextUnit(
`Skip loop detected: ${unitType} ${unitId} skipped ${skipCount} times without advancing. Evicting completion record and forcing reconciliation.`,
"warning",
);
if (!active) return;
_skipDepth++;
await new Promise(r => setTimeout(r, 50));
await new Promise(r => setTimeout(r, 150));
await dispatchNextUnit(ctx, pi);
_skipDepth = Math.max(0, _skipDepth - 1);
return;
}
// Count toward lifetime cap so hard-stop fires during skip loops (#792)
const lifeSkip = (unitLifetimeDispatches.get(idempotencyKey) ?? 0) + 1;
unitLifetimeDispatches.set(idempotencyKey, lifeSkip);
if (lifeSkip > MAX_LIFETIME_DISPATCHES) {
await stopAuto(ctx, pi, `Hard loop: ${unitType} ${unitId} (skip cycle)`);
ctx.ui.notify(
`Hard loop detected: ${unitType} ${unitId} hit lifetime cap during skip cycle (${lifeSkip} iterations).`,
"error",
);
return;
}
ctx.ui.notify(
`Skipping ${unitType} ${unitId} — already completed in a prior session. Advancing.`,
"info",
);
if (!active) return;
_skipDepth++;
await new Promise(r => setTimeout(r, 50));
await new Promise(r => setTimeout(r, 150));
await dispatchNextUnit(ctx, pi);
_skipDepth = Math.max(0, _skipDepth - 1);
return;
@ -2473,18 +2486,31 @@ async function dispatchNextUnit(
`Skip loop detected: ${unitType} ${unitId} skipped ${skipCount2} times without advancing. Evicting completion record and forcing reconciliation.`,
"warning",
);
if (!active) return;
_skipDepth++;
await new Promise(r => setTimeout(r, 50));
await new Promise(r => setTimeout(r, 150));
await dispatchNextUnit(ctx, pi);
_skipDepth = Math.max(0, _skipDepth - 1);
return;
}
// Count toward lifetime cap so hard-stop fires during skip loops (#792)
const lifeSkip2 = (unitLifetimeDispatches.get(idempotencyKey) ?? 0) + 1;
unitLifetimeDispatches.set(idempotencyKey, lifeSkip2);
if (lifeSkip2 > MAX_LIFETIME_DISPATCHES) {
await stopAuto(ctx, pi, `Hard loop: ${unitType} ${unitId} (skip cycle)`);
ctx.ui.notify(
`Hard loop detected: ${unitType} ${unitId} hit lifetime cap during skip cycle (${lifeSkip2} iterations).`,
"error",
);
return;
}
ctx.ui.notify(
`Skipping ${unitType} ${unitId} — artifact exists but completion key was missing. Repaired and advancing.`,
"info",
);
if (!active) return;
_skipDepth++;
await new Promise(r => setTimeout(r, 50));
await new Promise(r => setTimeout(r, 150));
await dispatchNextUnit(ctx, pi);
_skipDepth = Math.max(0, _skipDepth - 1);
return;