Skip to content

Commit 2c15d89

Browse files
committed
Log chunk deletion scheduling errors instead of returning them in goroutines
1 parent a4a9f27 commit 2c15d89

1 file changed

Lines changed: 5 additions & 1 deletion

File tree

pkg/controller/blob_to_chunk_controller.go

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -782,7 +782,11 @@ func (c *BlobToChunkController) createChunks(ctx context.Context, blob *v1alpha1
782782
chunk, err := c.chunkInformer.Lister().Get(name)
783783
if err == nil && chunk.Status.Phase == v1alpha1.ChunkPhaseSucceeded {
784784
g.Go(func() error {
785-
return c.scheduleChunkDeletion(ctx, name)
785+
err := c.scheduleChunkDeletion(ctx, name)
786+
if err != nil {
787+
klog.Errorf("failed to schedule deletion for chunk %s: %v", name, err)
788+
}
789+
return nil
786790
})
787791
}
788792
}

0 commit comments

Comments
 (0)