diff --git a/internal/metamorph/processor.go b/internal/metamorph/processor.go index 48ee3184d..ebecd8df8 100644 --- a/internal/metamorph/processor.go +++ b/internal/metamorph/processor.go @@ -487,11 +487,6 @@ func (p *Processor) checkAndUpdate(ctx context.Context) error { p.logger.Error("failed to bulk update statuses", slog.String("err", err.Error())) } - err = p.clearCache(statusUpdatesMap) - if err != nil { - p.logger.Error("failed to clear status update cache", slog.String("err", err.Error())) - } - return nil } diff --git a/internal/metamorph/processor_helpers.go b/internal/metamorph/processor_helpers.go index affb95315..717d912b9 100644 --- a/internal/metamorph/processor_helpers.go +++ b/internal/metamorph/processor_helpers.go @@ -96,15 +96,6 @@ func (p *Processor) getAndDeleteAllTransactionStatuses() (StatusUpdateMap, error return statuses, nil } -func (p *Processor) clearCache(updateStatusMap StatusUpdateMap) error { - keys := make([]string, len(updateStatusMap)) - for k := range updateStatusMap { - keys = append(keys, k.String()) - } - - return p.cacheStore.Del(&CacheStatusUpdateHash, keys...) -} - func (p *Processor) getStatusUpdateCount() (int, error) { count, err := p.cacheStore.CountElementsForHash(CacheStatusUpdateHash) if err != nil {