@@ -587,7 +587,7 @@ func (gceCS *GCEControllerServer) CreateSnapshot(ctx context.Context, req *csi.C
587
587
588
588
// Check if snapshot already exists
589
589
var snapshot * compute.Snapshot
590
- snapshot , err = gceCS .CloudProvider .GetSnapshot (ctx , gceCS . CloudProvider . GetDefaultProject () , req .Name )
590
+ snapshot , err = gceCS .CloudProvider .GetSnapshot (ctx , project , req .Name )
591
591
if err != nil {
592
592
if ! gce .IsGCEError (err , "notFound" ) {
593
593
return nil , status .Error (codes .Internal , fmt .Sprintf ("Unknown get snapshot error: %v" , err ))
@@ -673,15 +673,15 @@ func (gceCS *GCEControllerServer) DeleteSnapshot(ctx context.Context, req *csi.D
673
673
return nil , status .Error (codes .InvalidArgument , "DeleteSnapshot Snapshot ID must be provided" )
674
674
}
675
675
676
- _ , key , err := common .SnapshotIDToProjectKey (snapshotID )
676
+ project , key , err := common .SnapshotIDToProjectKey (snapshotID )
677
677
if err != nil {
678
678
// Cannot get snapshot ID from the passing request
679
679
// This is a success according to the spec
680
680
klog .Warningf ("Snapshot id does not have the correct format %s" , snapshotID )
681
681
return & csi.DeleteSnapshotResponse {}, nil
682
682
}
683
683
684
- err = gceCS .CloudProvider .DeleteSnapshot (ctx , gceCS . CloudProvider . GetDefaultProject () , key )
684
+ err = gceCS .CloudProvider .DeleteSnapshot (ctx , project , key )
685
685
if err != nil {
686
686
return nil , status .Error (codes .Internal , fmt .Sprintf ("unknown Delete snapshot error: %v" , err ))
687
687
}
0 commit comments