MirrorSave
/
budibase
mirror of https://github.com/Budibase/budibase.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Fix test

This commit is contained in:
Adria Navarro 2025-03-21 10:29:19 +01:00
parent ec02ce76ad
commit c91f3cfb39
1 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
packages/backend-core/src/queue/inMemoryQueue.ts
View File

@ -109,6 +109,12 @@ export class InMemoryQueue<T = any> implements Partial<Queue<T>> {
try {
await retryFunc(resp)
this._emitter.emit("completed", message as Job<T>)
const indexToRemove = this._messages.indexOf(message)
if (indexToRemove === -1) {
throw "Failed deleting a processed message"
}
this._messages.splice(indexToRemove, 1)
} catch (e: any) {
console.error(e)
}
@ -118,12 +124,6 @@ export class InMemoryQueue<T = any> implements Partial<Queue<T>> {
if (jobId && message.opts?.removeOnComplete) {
this._queuedJobIds.delete(jobId)
}
const indexToRemove = this._messages.indexOf(message)
if (indexToRemove === -1) {
throw "Failed deleting a processed message"
}
this._messages.splice(indexToRemove, 1)
})
}