@@ -761,7 +761,7 @@ func (c *BlocksCleaner) cleanUser(ctx context.Context, userLogger log.Logger, us
761
761
}
762
762
763
763
func (c * BlocksCleaner ) cleanPartitionedGroupInfo (ctx context.Context , userBucket objstore.InstrumentedBucket , userLogger log.Logger , userID string ) {
764
- err , existentPartitionedGroupInfo := c .iterPartitionGroups (ctx , userBucket , userLogger )
764
+ existentPartitionedGroupInfo , err := c .iterPartitionGroups (ctx , userBucket , userLogger )
765
765
if err != nil {
766
766
level .Warn (userLogger ).Log ("msg" , "error return when going through partitioned group directory" , "err" , err )
767
767
}
@@ -800,7 +800,7 @@ func (c *BlocksCleaner) cleanPartitionedGroupInfo(ctx context.Context, userBucke
800
800
}
801
801
802
802
func (c * BlocksCleaner ) emitUserMetrics (ctx context.Context , userLogger log.Logger , userBucket objstore.InstrumentedBucket , userID string ) {
803
- err , existentPartitionedGroupInfo := c .iterPartitionGroups (ctx , userBucket , userLogger )
803
+ existentPartitionedGroupInfo , err := c .iterPartitionGroups (ctx , userBucket , userLogger )
804
804
if err != nil {
805
805
level .Warn (userLogger ).Log ("msg" , "error return when going through partitioned group directory" , "err" , err )
806
806
}
@@ -829,10 +829,10 @@ func (c *BlocksCleaner) emitUserMetrics(ctx context.Context, userLogger log.Logg
829
829
}
830
830
}
831
831
832
- func (c * BlocksCleaner ) iterPartitionGroups (ctx context.Context , userBucket objstore.InstrumentedBucket , userLogger log.Logger ) (error , map [* PartitionedGroupInfo ]struct {
832
+ func (c * BlocksCleaner ) iterPartitionGroups (ctx context.Context , userBucket objstore.InstrumentedBucket , userLogger log.Logger ) (map [* PartitionedGroupInfo ]struct {
833
833
path string
834
834
status PartitionedGroupStatus
835
- }) {
835
+ }, error ) {
836
836
existentPartitionedGroupInfo := make (map [* PartitionedGroupInfo ]struct {
837
837
path string
838
838
status PartitionedGroupStatus
@@ -858,7 +858,7 @@ func (c *BlocksCleaner) iterPartitionGroups(ctx context.Context, userBucket objs
858
858
}
859
859
return nil
860
860
})
861
- return err , existentPartitionedGroupInfo
861
+ return existentPartitionedGroupInfo , err
862
862
}
863
863
864
864
// cleanUserPartialBlocks delete partial blocks which are safe to be deleted. The provided partials map
0 commit comments