Develop

src/modules/crawler/job-unlock.provider.ts

@@ -141,7 +141,6 @@ export class JobUnlockProvider {
             age: this.jobRemoveDueDate,
           },
           backoff: this.signatureJobBackOff,
-          jobId: `validate-signature-${data.eventLogId}-${i}`,
         },
       );
     }
@@ -166,7 +165,6 @@ export class JobUnlockProvider {
           age: this.jobRemoveDueDate,
         },
         backoff: this.sendTxJobBackOff,
-        jobId: `send-tx-${data.eventLogId}`,
       },
     );
   }

src/shared/modules/queue/queue.service.ts

@@ -43,7 +43,10 @@ export class QueueService {
     const queue = this.initQueueOnDemand(queueName);
     if (!!options.jobId) {
       const canContinue = await this.removeExistedJobIfFailed(options.jobId, queue);
-      if (!canContinue) return false;
+      if (!canContinue) {
+        this.logger.warn('this job is existed in queue and not in failed status');
+        return false;
+      }
     }
     await queue.add(job, options);
     return true;