Check for volume group existing before updating vg metadata

Reduce new image tag to below 1.14, bump it from 1.13.2 to 1.13.3

Replace return with continue so we don't break out of infinite loop

Author: cemakd

deploy/kubernetes/images/stable-master/image.yaml

@@ -51,5 +51,5 @@ imageTag:
   name: gke.gcr.io/gcp-compute-persistent-disk-csi-driver
   # pdImagePlaceholder in test/k8s-integration/main.go is updated automatically with the newTag
   newName: registry.k8s.io/cloud-provider-gcp/gcp-compute-persistent-disk-csi-driver
-  newTag: "v1.17.2"
+  newTag: "v1.13.3"
 ---

pkg/gce-pd-csi-driver/cache.go

@@ -618,17 +618,23 @@ func watchDiskDetaches(watcher *fsnotify.Watcher, nodeName string, errorCh chan
 			errorCh <- fmt.Errorf("disk update event errored: %v", err)
 		// watch for events
 		case <-watcher.Events:
+			vgName := getVolumeGroupName(nodeName)
+			if !checkVgExists(vgName) {
+				// If the volume group doesn't exist, there's nothing to update.
+				// Continue to the next event.
+				continue
+			}
 			// In case of an event i.e. creation or deletion of any new PV, we update the VG metadata.
 			// This might include some non-LVM changes, no harm in updating metadata multiple times.
 			args := []string{
 				"--updatemetadata",
-				getVolumeGroupName(nodeName),
+				vgName,
 			}
 			_, err := common.RunCommand("" /* pipedCmd */, nil /* pipedCmdArg */, "vgck", args...)
 			if err != nil {
 				klog.Errorf("Error updating volume group's metadata: %v", err)
 			}
-			reduceVolumeGroup(getVolumeGroupName(nodeName), true)
+			reduceVolumeGroup(vgName, true)
 		}
 	}
 }