complete a message if the stored message is not found

ericallam · ericallam · commit 4ce106606ba2 · 2026-01-07T14:22:05.000Z
diff --git a/internal-packages/run-engine/src/batch-queue/index.ts b/internal-packages/run-engine/src/batch-queue/index.ts
@@ -684,6 +684,7 @@ export class BatchQueue {
 
     if (!storedMessage) {
       this.logger.error("Message not found in in-flight data", { messageId, queueId });
+      await this.fairQueue.completeMessage(messageId, queueId);
       return;
     }
 

Original file line number	Diff line number	Diff line change
`@@ -684,6 +684,7 @@ export class BatchQueue {`
`684`	`684`
`685`	`685`	`if (!storedMessage) {`
`686`	`686`	`this.logger.error("Message not found in in-flight data", { messageId, queueId });`
	`687`	`+ await this.fairQueue.completeMessage(messageId, queueId);`
`687`	`688`	`return;`
`688`	`689`	`}`
`689`	`690`