storage: fix az delete obj bug (#81)

Signed-off-by: huanghaoyuanhhy <[email protected]>
zilliztech · Mar 5, 2024 · 658b5fa · 658b5fa
1 parent 76f3ae3
commit 658b5fa
Showing 1 changed file with 6 additions and 2 deletions.
diff --git a/storage/azure.go b/storage/azure.go
@@ -271,9 +271,13 @@ func (a *AzureClient) DeleteObjects(ctx context.Context, i DeleteObjectsInput) e
 	wp.Start()
 
 	for _, key := range i.Keys {
-		if _, err := a.cli.DeleteBlob(ctx, i.Bucket, key, nil); err != nil {
-			return fmt.Errorf("storage: azure delete object %w", err)
+		job := func(ctx context.Context) error {
+			if _, err := a.cli.DeleteBlob(ctx, i.Bucket, key, nil); err != nil {
+				return fmt.Errorf("storage: azure delete object %w", err)
+			}
+			return nil
 		}
+		wp.Submit(job)
 	}
 	wp.Done()