fix: ensure task deletion occurs after acknowledgment in Redis worker stream

Author: EastSun5566

src/api.js

@@ -300,8 +300,8 @@ export class Api {
       if (streamlen === 0) {
         await this.redis.multi()
           .xDelIfEmpty(task.stream)
-          .xDel(this.redisWorkerStreamName, task.id)
           .xAck(this.redisWorkerStreamName, this.redisWorkerGroupName, task.id)
+          .xDel(this.redisWorkerStreamName, task.id)
           .sRem(this.workerSetName, task.stream)
           .exec()
         logWorker('Stream still empty, removing recurring task from queue ', { stream: task.stream })
@@ -319,8 +319,8 @@ export class Api {
           this.redis.multi()
             .xTrim(task.stream, 'MINID', lastId - this.redisMinMessageLifetime)
             .xAdd(this.redisWorkerStreamName, '*', { compact: task.stream })
-            .xDel(this.redisWorkerStreamName, task.id)
             .xAck(this.redisWorkerStreamName, this.redisWorkerGroupName, task.id)
+            .xDel(this.redisWorkerStreamName, task.id)
             .sAdd(this.workerSetName, task.stream)
             .exec()
         ])