Skip to content

Commit 5e80ba3

Browse files
committed
Pass the batchId through from previous snapshots when dequeuing
1 parent 32d2992 commit 5e80ba3

File tree

2 files changed

+3
-0
lines changed

2 files changed

+3
-0
lines changed

internal-packages/run-engine/src/engine/systems/dequeueSystem.ts

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -374,6 +374,7 @@ export class DequeueSystem {
374374
projectId: snapshot.projectId,
375375
organizationId: snapshot.organizationId,
376376
checkpointId: snapshot.checkpointId ?? undefined,
377+
batchId: snapshot.batchId ?? undefined,
377378
completedWaitpoints: snapshot.completedWaitpoints,
378379
workerId,
379380
runnerId,

internal-packages/run-engine/src/engine/systems/runAttemptSystem.ts

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -218,6 +218,8 @@ export class RunAttemptSystem {
218218
environmentType: latestSnapshot.environmentType,
219219
projectId: latestSnapshot.projectId,
220220
organizationId: latestSnapshot.organizationId,
221+
batchId: latestSnapshot.batchId ?? undefined,
222+
completedWaitpoints: latestSnapshot.completedWaitpoints,
221223
workerId,
222224
runnerId,
223225
});

0 commit comments

Comments
 (0)