fix: retry failed projection resume batch

2026-06-19 17:05:48 +08:00
parent 1db6016ffc
commit 6dbf668a5d
1 changed files with 1 additions and 1 deletions
@@ -899,7 +899,7 @@ export function startAgentRunProjectionResume({ options = {}, traceStore = defau
      void runAgentRunProjectionResumePass({ options, traceStore, logger, batchSize, minAgeMs, offset, reason })
        .then((result) => {
          failed = result?.failed > 0;
-          nextOffset = result?.scannedSessions >= batchSize ? offset + batchSize : 0;
+          nextOffset = failed ? offset : (result?.scannedSessions >= batchSize ? offset + batchSize : 0);
        })
        .catch((error) => {
          failed = true;