Remove obsolete job

zkBob · Jul 10, 2024 · 5e21934 · 5e21934
1 parent 404597f
commit 5e21934
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 4 deletions.
diff --git a/zp-relayer/pool/BasePool.ts b/zp-relayer/pool/BasePool.ts
@@ -179,7 +179,7 @@ export abstract class BasePool<N extends Network = Network> {
       newLocalIndex,
     })
     if (newLocalIndex < contractIndex) {
-      throw new Error('Indexer is not syncronized with the contract yet')
+      throw new Error('Indexer is not synchronized with the contract yet')
     }
     if (newLocalRoot !== contractRoot) {
       throw new Error('State is corrupted, roots mismatch')

diff --git a/zp-relayer/services/commitment-watcher/init.ts b/zp-relayer/services/commitment-watcher/init.ts
@@ -28,9 +28,14 @@ async function processCommitment(pendingCommitment: PendingCommitment) {
   }
 
   const existingJob = await poolTxQueue.getJob(commitment);
-  if (existingJob && existingJob.data.transaction.state !== JobState.FAILED) {
-    logger.info('Job already created, waiting...', { commitment })
-    return
+  if (existingJob) {
+    if (existingJob.data.transaction.state === JobState.FAILED) {
+      logger.info('Job failed, repeating...', { commitment })
+      await poolTxQueue.remove(commitment);
+    } else {
+      logger.info('Job already created, waiting...', { commitment })
+      return
+    }
   }
 
   const job = await poolTxQueue.add(