use node parameter to handle the sanity test failure

Signed-off-by: prateekpandey14 <prateek.pandey@mayadata.io>

pkg/driver/controller.go

@@ -200,15 +200,20 @@ func CreateZFSVolume(req *csi.CreateVolumeRequest) (string, error) {
 		return "", status.Errorf(codes.Internal, "get node map failed : %s", err.Error())
 	}
 
-	// run the scheduler
-	selected := schd.Scheduler(req, nmap)
+	// run the scheduler get the preferred nodelist
+	nodelist := schd.Scheduler(req, nmap)
+
+	selected := nodelist[0]
 
 	if len(selected) == 0 {
-		return "", status.Error(codes.Internal, "scheduler failed, not able to select a node to create the PV")
+		// (hack): CSI Sanity test does not pass topology information
+		selected = parameters["node"]
+		if len(selected) == 0 {
+			return "", status.Error(codes.Internal, "scheduler failed, not able to select a node to create the PV")
+		}
 	}
 
-	owner := selected[0]
-	klog.Infof("scheduling the volume %s/%s on node %s", pool, volName, owner)
+	klog.Infof("scheduling the volume %s/%s on node %s", pool, volName, selected)
 
 	volObj, err := volbuilder.NewBuilder().
 		WithName(volName).
@@ -221,7 +226,7 @@ func CreateZFSVolume(req *csi.CreateVolumeRequest) (string, error) {
 		WithKeyFormat(kf).
 		WithKeyLocation(kl).
 		WithThinProv(tp).
-		WithOwnerNode(owner).
+		WithOwnerNode(selected).
 		WithVolumeType(vtype).
 		WithVolumeStatus(zfs.ZFSStatusPending).
 		WithFsType(fstype).