diff --git a/src/modules/did/did.service.ts b/src/modules/did/did.service.ts index 981fa1cb..0180e8b8 100644 --- 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 index c3df2150..50e64756 100644 --- 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; }