@@ -477,13 +477,15 @@ def update_blueprint(self) -> bool:
477477 _blueprint_id : str = blueprint .get ("id" , "" )
478478 _endpoint : str = f"projects/{ self .project_id } /blueprints/{ _blueprint_id } "
479479 # Handle disk blueprints since we don't want provisioned IOPS $$$$
480+ new_disks = []
480481 for disk in blueprint ["disks" ]:
481- blueprint [ "disks" ] = [
482+ new_disks . append (
482483 {
483484 "type" : self .config .active_config .get ("disk_type" , "SSD" ),
484485 "name" : disk .get ("name" , "" ),
485486 }
486- ]
487+ )
488+ blueprint ["disks" ] = new_disks
487489
488490 # Update machine tags
489491 blueprint ["tags" ] = [
@@ -885,7 +887,7 @@ def copy_image(self, image_id: str) -> str:
885887 aws_session_token = credentials ["SessionToken" ],
886888 )
887889
888- print (f"Copying image { image_id } " )
890+ print (f"Copying image { image_id } with KMS: { self . destination_kms } " )
889891 new_image : Dict [str , Any ] = _ec2_client .copy_image (
890892 SourceImageId = image_id ,
891893 SourceRegion = AWS_REGION ,
@@ -1064,7 +1066,9 @@ def terminate(self) -> bool:
10641066 ) or _machine == source_props .get ("machineCloudId" , "NONE" ):
10651067 replica : str = machine .get ("replica" )
10661068 if replica :
1067- f"{ ref_name } has a launched machine: { replica } . Terminating."
1069+ print (
1070+ f"{ ref_name } has a launched machine: { replica } . Terminating."
1071+ )
10681072 data_dict : Dict [str , Any ] = {}
10691073 data_dict ["replicaIDs" ] = [replica ]
10701074
0 commit comments