diff --git a/pkg/csi/controller.go b/pkg/csi/controller.go index 2d82731..3454c4d 100644 --- a/pkg/csi/controller.go +++ b/pkg/csi/controller.go @@ -329,9 +329,9 @@ func (d *ControllerService) ControllerPublishVolume(_ context.Context, request * return nil, status.Error(codes.Internal, err.Error()) } - if vm.Node() != vol.Node() { - return nil, status.Error(codes.InvalidArgument, fmt.Sprintf("volume %s does not exist on the node %s", volumeID, nodeID)) - } + // if vm.Node() != vol.Node() { + // return nil, status.Error(codes.InvalidArgument, fmt.Sprintf("volume %s does not exist on the node %s", volumeID, nodeID)) + // } options := map[string]string{ "backup": "0", diff --git a/pkg/csi/controller_test.go b/pkg/csi/controller_test.go index a905ca4..bd1b168 100644 --- a/pkg/csi/controller_test.go +++ b/pkg/csi/controller_test.go @@ -813,17 +813,17 @@ func (ts *csiTestSuite) TestControllerPublishVolumeError() { }, expectedError: status.Error(codes.Internal, "proxmox cluster fake-region not found"), }, - { - msg: "WrongNode", - request: &proto.ControllerPublishVolumeRequest{ - NodeId: "cluster-1-node-2", - VolumeId: "cluster-1/pve-1/local-lvm/vm-9999-pvc-123", - VolumeCapability: volcap, - VolumeContext: volCtx, - Readonly: true, - }, - expectedError: status.Error(codes.InvalidArgument, "volume cluster-1/pve-1/local-lvm/vm-9999-pvc-123 does not exist on the node cluster-1-node-2"), - }, + // { + // msg: "WrongNode", + // request: &proto.ControllerPublishVolumeRequest{ + // NodeId: "cluster-1-node-2", + // VolumeId: "cluster-1/pve-1/local-lvm/vm-9999-pvc-123", + // VolumeCapability: volcap, + // VolumeContext: volCtx, + // Readonly: true, + // }, + // expectedError: status.Error(codes.InvalidArgument, "volume cluster-1/pve-1/local-lvm/vm-9999-pvc-123 does not exist on the node cluster-1-node-2"), + // }, { msg: "VolumeNotExist", request: &proto.ControllerPublishVolumeRequest{