mirrors/seaweedfs
1
0
Fork 0
mirror of https://github.com/seaweedfs/seaweedfs.git synced 2026-09-21 07:24:25 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix(azuresink): include DeleteSnapshots in cleanup delete

Browse Source 
Match the DeleteSnapshots option used in handleExistingBlob so cleanup
succeeds even if a snapshot was created by an automated policy.
This commit is contained in:
Chris Lu
2026-04-05 16:17:38 -07:00
parent e84b96f346
commit 84d65b3905
1 changed files with 3 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
weed/replication/sink/azuresink/azure_sink.go
+3 -1
View File
@@ -170,7 +170,9 @@ func (g *AzureSink) CreateEntry(key string, entry *filer_pb.Entry, signatures []
glog.Warningf("azure sink: cleaning up empty blob %s/%s after write failure: %v", g.container, key, writeErr)
ctxCleanup, cancelCleanup := context.WithTimeout(context.Background(), azure.DefaultAzureOpTimeout)
defer cancelCleanup()
if _, delErr := appendBlobClient.Delete(ctxCleanup, nil); delErr != nil {
if _, delErr := appendBlobClient.Delete(ctxCleanup, &blob.DeleteOptions{
DeleteSnapshots: to.Ptr(blob.DeleteSnapshotsOptionTypeInclude),
}); delErr != nil {
if !bloberror.HasCode(delErr, bloberror.BlobNotFound) {
glog.Warningf("azure sink: failed to clean up blob %s/%s: %v", g.container, key, delErr)
}