@@ -86,7 +86,7 @@ func (b *bucketClaimListener) Update(ctx context.Context, old, new *v1alpha1.Buc
86
86
87
87
// Delete processes a bucket for which bucket request is deleted
88
88
func (b * bucketClaimListener ) Delete (ctx context.Context , bucketClaim * v1alpha1.BucketClaim ) error {
89
- klog .V (3 ).Infof ("Delete BucketClaim %v " ,
89
+ klog .V (3 ).Infof ("Delete BucketClaim" ,
90
90
"name" , bucketClaim .ObjectMeta .Name ,
91
91
"ns" , bucketClaim .ObjectMeta .Namespace )
92
92
@@ -172,8 +172,11 @@ func (b *bucketClaimListener) provisionBucketClaimOperation(ctx context.Context,
172
172
bucketClaim .Status .BucketReady = false
173
173
}
174
174
175
- _ , err = b .bucketClaims (bucketClaim .ObjectMeta .Namespace ).UpdateStatus (ctx , bucketClaim , metav1.UpdateOptions {})
175
+ // Fetching the updated bucketClaim again, so that the update
176
+ // operation doesn't happen on an outdated version of the bucketClaim.
177
+ bucketClaim , err = b .bucketClaims (bucketClaim .ObjectMeta .Namespace ).UpdateStatus (ctx , bucketClaim , metav1.UpdateOptions {})
176
178
if err != nil {
179
+ klog .ErrorS (err , "Failed to update status of BucketClaim" , "name" , bucketClaim .ObjectMeta .Name )
177
180
return err
178
181
}
179
182
@@ -182,8 +185,10 @@ func (b *bucketClaimListener) provisionBucketClaimOperation(ctx context.Context,
182
185
controllerutil .AddFinalizer (bucketClaim , util .BucketClaimFinalizer )
183
186
_ , err = b .bucketClaims (bucketClaim .ObjectMeta .Namespace ).Update (ctx , bucketClaim , metav1.UpdateOptions {})
184
187
if err != nil {
188
+ klog .ErrorS (err , "Failed to update BucketClaim" , "name" , bucketClaim .ObjectMeta .Name )
185
189
return err
186
190
}
191
+
187
192
klog .Infof ("Finished creating Bucket %v" , bucketName )
188
193
return nil
189
194
}
0 commit comments