Merge pull request #164 from sotatek-dev/develop

Develop
sotatek-dev · Oct 9, 2024 · 063d436 · 063d436
2 parents e3dd626 + 357b948
commit 063d436
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 3 deletions.
diff --git a/src/modules/crawler/job-unlock.provider.ts b/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}`,
       },
     );
   }

diff --git a/src/shared/modules/queue/queue.service.ts b/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;