Clean

packages/backend-core/src/queue/inMemoryQueue.ts

@@ -68,7 +68,6 @@ class InMemoryQueue implements Partial<Queue> {
    */
   async process(func: any) {
     this._emitter.on("message", async () => {
-      try {
       if (this._messages.length <= 0) {
         return
       }
@@ -83,9 +82,6 @@ class InMemoryQueue implements Partial<Queue> {
       if (jobId && msg?.opts?.removeOnComplete) {
         this._queuedJobIds.delete(jobId)
       }
-      } catch (e: any) {
-        throw e
-      }
     })
   }