chore: cancel empty queue on error

energywebfoundation · Aug 7, 2023 · 4ff6281 · 4ff6281
1 parent f63eb1c
commit 4ff6281
Show file tree

Hide file tree

Showing 2 changed files with 0 additions and 12 deletions.
diff --git a/src/modules/did/did.service.ts b/src/modules/did/did.service.ts
@@ -493,12 +493,6 @@ export class DIDService implements OnModuleInit, OnModuleDestroy {
       );
       const jobsCounts = await this.didQueue.getJobCounts();
       this.logger.debug(inspect(jobsCounts, { depth: 2, colors: true }));
-      if (/OOM/.test(String(e))) {
-        this.logger.warn(
-          `Redis exceeded memory limit. Removing waiting jobs from DID queue`
-        );
-        await this.didQueue.empty();
-      }
     }
   }
 }
diff --git a/src/modules/ipfs/ipfs.service.ts b/src/modules/ipfs/ipfs.service.ts
@@ -72,12 +72,6 @@ export class IPFSService {
       this.logger.debug(`Error to add pin job for cid ${cid}: ${e}`);
       const jobsCounts = await this.pinsQueue.getJobCounts();
       this.logger.debug(inspect(jobsCounts, { depth: 2, colors: true }));
-      if (/OOM/.test(String(e))) {
-        this.logger.warn(
-          `Redis exceeded memory limit. Removing waiting jobs from PIN queue`
-        );
-        await this.pinsQueue.empty();
-      }
     }
     return claim;
   }