mirror of
https://github.com/k3s-io/kubernetes.git
synced 2025-08-05 10:19:50 +00:00
Azure disk volume: Do not report error when deleting an attached volume
This commit is contained in:
parent
41d7acc0f5
commit
307de20753
@ -30,6 +30,7 @@ go_library(
|
|||||||
"//pkg/cloudprovider:go_default_library",
|
"//pkg/cloudprovider:go_default_library",
|
||||||
"//pkg/types:go_default_library",
|
"//pkg/types:go_default_library",
|
||||||
"//pkg/util/errors:go_default_library",
|
"//pkg/util/errors:go_default_library",
|
||||||
|
"//pkg/volume:go_default_library",
|
||||||
"//vendor:github.com/Azure/azure-sdk-for-go/arm/compute",
|
"//vendor:github.com/Azure/azure-sdk-for-go/arm/compute",
|
||||||
"//vendor:github.com/Azure/azure-sdk-for-go/arm/network",
|
"//vendor:github.com/Azure/azure-sdk-for-go/arm/network",
|
||||||
"//vendor:github.com/Azure/azure-sdk-for-go/arm/storage",
|
"//vendor:github.com/Azure/azure-sdk-for-go/arm/storage",
|
||||||
|
@ -24,6 +24,7 @@ import (
|
|||||||
"github.com/golang/glog"
|
"github.com/golang/glog"
|
||||||
"k8s.io/kubernetes/pkg/cloudprovider"
|
"k8s.io/kubernetes/pkg/cloudprovider"
|
||||||
"k8s.io/kubernetes/pkg/types"
|
"k8s.io/kubernetes/pkg/types"
|
||||||
|
"k8s.io/kubernetes/pkg/volume"
|
||||||
)
|
)
|
||||||
|
|
||||||
const (
|
const (
|
||||||
@ -235,6 +236,12 @@ func (az *Cloud) DeleteVolume(name, uri string) error {
|
|||||||
err = az.deleteVhdBlob(accountName, key, blob)
|
err = az.deleteVhdBlob(accountName, key, blob)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
glog.Warningf("failed to delete blob %s err: %v", uri, err)
|
glog.Warningf("failed to delete blob %s err: %v", uri, err)
|
||||||
|
detail := err.Error()
|
||||||
|
if strings.Contains(detail, "LeaseIdMissing") {
|
||||||
|
// disk is still being used
|
||||||
|
// see https://msdn.microsoft.com/en-us/library/microsoft.windowsazure.storage.blob.protocol.bloberrorcodestrings.leaseidmissing.aspx
|
||||||
|
return volume.NewDeletedVolumeInUseError(fmt.Sprintf("disk %q is still in use while being deleted", name))
|
||||||
|
}
|
||||||
return fmt.Errorf("failed to delete vhd %v, account %s, blob %s, err: %v", uri, accountName, blob, err)
|
return fmt.Errorf("failed to delete vhd %v, account %s, blob %s, err: %v", uri, accountName, blob, err)
|
||||||
}
|
}
|
||||||
glog.V(4).Infof("blob %s deleted", uri)
|
glog.V(4).Infof("blob %s deleted", uri)
|
||||||
|
Loading…
Reference in New Issue
Block a user