@@ -121,7 +121,7 @@ func (cs *controllerServer) CreateVolume(ctx context.Context, req *csi.CreateVol
121121 }
122122
123123 // Volume Create
124- properties := map [string ]string {cinderCSIClusterIDKey : cs .Driver .cluster }
124+ properties := map [string ]string {cinderCSIClusterIDKey : cs .Driver .clusterID }
125125 //Tag volume with metadata if present: https://github.com/kubernetes-csi/external-provisioner/pull/399
126126 for _ , mKey := range sharedcsi .RecognizedCSIProvisionerParams {
127127 if v , ok := req .Parameters [mKey ]; ok {
@@ -764,7 +764,7 @@ func (cs *controllerServer) createSnapshot(cloud openstack.IOpenStack, name stri
764764 }
765765
766766 // Add cluster ID to the snapshot metadata
767- properties := map [string ]string {cinderCSIClusterIDKey : cs .Driver .cluster }
767+ properties := map [string ]string {cinderCSIClusterIDKey : cs .Driver .clusterID }
768768
769769 // see https://github.com/kubernetes-csi/external-snapshotter/pull/375/
770770 // Also, we don't want to tag every param but we still want to send the
@@ -790,7 +790,7 @@ func (cs *controllerServer) createSnapshot(cloud openstack.IOpenStack, name stri
790790
791791func (cs * controllerServer ) createBackup (cloud openstack.IOpenStack , name string , volumeID string , snap * snapshots.Snapshot , parameters map [string ]string ) (* backups.Backup , error ) {
792792 // Add cluster ID to the snapshot metadata
793- properties := map [string ]string {cinderCSIClusterIDKey : cs .Driver .cluster }
793+ properties := map [string ]string {cinderCSIClusterIDKey : cs .Driver .clusterID }
794794
795795 // see https://github.com/kubernetes-csi/external-snapshotter/pull/375/
796796 // Also, we don't want to tag every param but we still want to send the
0 commit comments