Wrap with kv slowdown err

treeverse · Apr 15, 2024 · 6985568 · 6985568
1 parent 1e6647b
commit 6985568
Showing 1 changed file with 1 addition and 0 deletions.
diff --git 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)
 	}