diff --git a/pkg/compute/models/buckets.go b/pkg/compute/models/buckets.go index 1d799dc8f4..55ba42284b 100644 --- a/pkg/compute/models/buckets.go +++ b/pkg/compute/models/buckets.go @@ -939,6 +939,9 @@ func (bucket *SBucket) PerformUpload( if err := quotas.CheckSetPendingQuota(ctx, userCred, &pendingUsage); err != nil { return nil, httperrors.NewOutOfQuotaError("%s", err) } + + // always cancel pending usage + defer quotas.CancelPendingUsage(ctx, userCred, &pendingUsage, &pendingUsage) } err = cloudprovider.UploadObject(ctx, iBucket, key, 0, appParams.Request.Body, sizeBytes, cloudprovider.TBucketACLType(aclStr), storageClass, meta, false) @@ -951,10 +954,6 @@ func (bucket *SBucket) PerformUpload( bucket.syncWithCloudBucket(ctx, userCred, iBucket, nil, true) - if !pendingUsage.IsEmpty() { - quotas.CancelPendingUsage(ctx, userCred, &pendingUsage, &pendingUsage) - } - return nil, nil }