Only for testing

kubernetes · Jan 6, 2021 · ee73375 · ee73375
1 parent 242e07d
commit ee73375
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/staging/src/k8s.io/csi-translation-lib/plugins/azure_disk.go b/staging/src/k8s.io/csi-translation-lib/plugins/azure_disk.go
@@ -178,6 +178,9 @@ func (t *azureDiskCSITranslator) TranslateInTreePVToCSI(pv *v1.PersistentVolume)
 // TranslateCSIPVToInTree takes a PV with CSIPersistentVolumeSource set and
 // translates the Azure Disk CSI source to a AzureDisk source.
 func (t *azureDiskCSITranslator) TranslateCSIPVToInTree(pv *v1.PersistentVolume) (*v1.PersistentVolume, error) {
+	if pv == nil || pv.Spec.CSI == nil {
+		return nil, fmt.Errorf("pv is nil or CSI source not defined on pv")
+	}
 	if pv == nil || pv.Spec.CSI == nil {
 		return nil, fmt.Errorf("pv is nil or CSI source not defined on pv")
 	}