Skip to content

Commit 1d2faf1

Browse files
committed
Remove old cleanup status before create new pv
1 parent 8571396 commit 1d2faf1

File tree

1 file changed

+7
-0
lines changed

1 file changed

+7
-0
lines changed

pkg/discovery/discovery.go

Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -307,6 +307,13 @@ func (d *Discoverer) discoverVolumesAtPath(class string, config common.MountConf
307307
continue
308308
}
309309

310+
// remove old cleanup status
311+
_, _, err = d.CleanupTracker.RemoveStatus(pvName, usejob)
312+
if err != nil {
313+
klog.Errorf("expected status exists and fail to remove cleanup status for pv %s", pvName)
314+
continue
315+
}
316+
310317
mountOptions, err := d.getMountOptionsFromStorageClass(class)
311318
if err != nil {
312319
discoErrors = append(discoErrors, fmt.Errorf("failed to get mount options from storage class %s: %v", class, err))

0 commit comments

Comments
 (0)