Remove old cleanup status before create new pv

kubernetes-sigs · Feb 18, 2020 · 1d2faf1 · 1d2faf1
1 parent 8571396
commit 1d2faf1
Showing 1 changed file with 7 additions and 0 deletions.
diff --git a/pkg/discovery/discovery.go b/pkg/discovery/discovery.go
@@ -307,6 +307,13 @@ func (d *Discoverer) discoverVolumesAtPath(class string, config common.MountConf
 			continue
 		}
 
+		// remove old cleanup status
+		_, _, err = d.CleanupTracker.RemoveStatus(pvName, usejob)
+		if err != nil {
+			klog.Errorf("expected status exists and fail to remove cleanup status for pv %s", pvName)
+			continue
+		}
+
 		mountOptions, err := d.getMountOptionsFromStorageClass(class)
 		if err != nil {
 			discoErrors = append(discoErrors, fmt.Errorf("failed to get mount options from storage class %s: %v", class, err))