Skip to content

Commit

Permalink
fix(ARCO-283): fix PR comments
Browse files Browse the repository at this point in the history
  • Loading branch information
pawellewandowski98 committed Nov 27, 2024
1 parent 7158db0 commit fc19ee8
Show file tree
Hide file tree
Showing 2 changed files with 2 additions and 4 deletions.
5 changes: 1 addition & 4 deletions internal/cache/redis.go
Original file line number Diff line number Diff line change
Expand Up @@ -85,14 +85,11 @@ func (r *RedisStore) MapSet(hashsetKey string, key string, value []byte) error {

// MapDel removes a value by key in specific hashsetKey.
func (r *RedisStore) MapDel(hashsetKey string, keys ...string) error {
result, err := r.client.HDel(r.ctx, hashsetKey, keys...).Result()
err := r.client.HDel(r.ctx, hashsetKey, keys...).Err()

if err != nil {
return errors.Join(ErrCacheFailedToDel, err)
}
if result == 0 {
return ErrCacheNotFound
}

return nil
}
Expand Down
1 change: 1 addition & 0 deletions internal/metamorph/processor_helpers.go
Original file line number Diff line number Diff line change
Expand Up @@ -92,6 +92,7 @@ func (p *Processor) getAndDeleteAllTransactionStatuses() (StatusUpdateMap, error
err = json.Unmarshal(value, &status)
if err != nil {
p.logger.Error("failed to unmarshal status", slog.String("error", err.Error()), slog.String("key", key))
continue
}

statuses[*hash] = status
Expand Down

0 comments on commit fc19ee8

Please sign in to comment.