diff --git a/src/modules/crawler/job-unlock.provider.ts b/src/modules/crawler/job-unlock.provider.ts index 8ff9158..55ea408 100644 --- 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 index 792b710..c1d592c 100644 --- 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;