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),