Expire cache entries immediately in case of errors

9 months ago · a8c2fa31dd
1 changed files with 3 additions and 1 deletions
--- a/apps/api/src/services/queues/portfolio-snapshot/portfolio-snapshot.processor.ts
+++ b/apps/api/src/services/queues/portfolio-snapshot/portfolio-snapshot.processor.ts
@ -86,7 +86,9 @@ export class PortfolioSnapshotProcessor {

      const expiration = addMilliseconds(
        new Date(),
-        this.configurationService.get('CACHE_QUOTES_TTL')
+        snapshot.errors.length === 0
+          ? this.configurationService.get('CACHE_QUOTES_TTL')
+          : 0
      );

      this.redisCacheService.set(