diff --git a/pkg/kv/dynamodb/store.go b/pkg/kv/dynamodb/store.go index 71fc4bb374c..c1caba48dbc 100644 --- a/pkg/kv/dynamodb/store.go +++ b/pkg/kv/dynamodb/store.go @@ -241,6 +241,7 @@ func (s *Store) Get(ctx context.Context, partitionKey, key []byte) (*kv.ValueWit if s.isSlowDownErr(err) { s.logger.WithField("partition_key", partitionKey).WithContext(ctx).Error("get item: %w", kv.ErrSlowDown) dynamoSlowdown.WithLabelValues(operation).Inc() + err = errors.Join(err, kv.ErrSlowDown) } return nil, fmt.Errorf("get item: %w", err) }