From 30b6c2c35edb2b5a78ca88bec212bf502bd08e20 Mon Sep 17 00:00:00 2001 From: nicktrn <55853254+nicktrn@users.noreply.github.com> Date: Fri, 3 May 2024 14:19:08 +0100 Subject: [PATCH] stop heartbeat timeout on non-inplace replace message --- apps/webapp/app/v3/marqs/index.server.ts | 2 ++ 1 file changed, 2 insertions(+) diff --git a/apps/webapp/app/v3/marqs/index.server.ts b/apps/webapp/app/v3/marqs/index.server.ts index c0eb62f98..f0b483938 100644 --- a/apps/webapp/app/v3/marqs/index.server.ts +++ b/apps/webapp/app/v3/marqs/index.server.ts @@ -458,6 +458,8 @@ export class MarQS { return; } + workerQueue.dequeue(`requeueTaskRun:${messageId}`); + await this.#callAcknowledgeMessage({ parentQueue: oldMessage.parentQueue, messageKey: this.keys.messageKey(messageId),