Ignore not found errors when compacting users

alanprot · alanprot · commit 8cfa15bef73f · 2022-09-19T14:47:31.000-07:00
Signed-off-by: Alan Protasio &lt;approtas@amazon.com&gt;
diff --git a/pkg/compactor/compactor.go b/pkg/compactor/compactor.go
@@ -732,7 +732,7 @@ func (c *Compactor) compactUserWithRetries(ctx context.Context, userID string) e
 }
 
 func (c *Compactor) compactUser(ctx context.Context, userID string) error {
-	bucket := bucket.NewUserBucketClient(userID, c.bucketClient, c.cfgProvider)
+	bucket := bucket.NewUserBucketClient(userID, c.bucketClient, c.cfgProvider).WithExpectedErrs(c.bucketClient.IsObjNotFoundErr)
 	reg := prometheus.NewRegistry()
 	defer c.syncerMetrics.gatherThanosSyncerMetrics(reg)
 

Original file line number	Diff line number	Diff line change
`@@ -732,7 +732,7 @@ func (c *Compactor) compactUserWithRetries(ctx context.Context, userID string) e`
`732`	`732`	`}`
`733`	`733`
`734`	`734`	`func (c *Compactor) compactUser(ctx context.Context, userID string) error {`
`735`		`- bucket := bucket.NewUserBucketClient(userID, c.bucketClient, c.cfgProvider)`
	`735`	`+ bucket := bucket.NewUserBucketClient(userID, c.bucketClient, c.cfgProvider).WithExpectedErrs(c.bucketClient.IsObjNotFoundErr)`
`736`	`736`	`reg := prometheus.NewRegistry()`
`737`	`737`	`defer c.syncerMetrics.gatherThanosSyncerMetrics(reg)`
`738`	`738`