@@ -51,7 +51,7 @@ def install_vme(
5151 continue
5252 except ResourceNotFoundError :
5353 # The extension does not exist, proceed with installation
54- print (f"Installing extension { extension_type } ..." )
54+ print (f"Installing extension { extension_type } ..." , flush = True )
5555 command = [
5656 str (shutil .which ("az" )),
5757 "k8s-extension" ,
@@ -70,7 +70,7 @@ def install_vme(
7070 "cluster"
7171 ]
7272 result = utils .call_subprocess_raise_output (command )
73- print (f"Installed extension { extension_type } successfully." )
73+ print (f"Installed extension { extension_type } successfully." , flush = True )
7474 print (result )
7575
7676 if len (include_extension_types ) > 1 :
@@ -97,7 +97,7 @@ def uninstall_vme(
9797
9898 # Uninstall the bundle extensions one by one
9999 for extension_type in include_extension_types :
100- print (f"Uninstalling extension { extension_type } ..." )
100+ print (f"Uninstalling extension { extension_type } ..." , flush = True )
101101 command = [str (shutil .which ("az" )),
102102 "k8s-extension" ,
103103 "delete" ,
@@ -113,7 +113,7 @@ def uninstall_vme(
113113 if force :
114114 command .append ("--force" )
115115 utils .call_subprocess_raise_output (command )
116- print (f"Uninstalled extension { extension_type } successfully." )
116+ print (f"Uninstalled extension { extension_type } successfully." , flush = True )
117117 if len (include_extension_types ) > 1 :
118118 print ("All extensions uninstalled successfully." )
119119
@@ -143,7 +143,7 @@ def upgrade_vme(
143143 cmd , subscription_id , cluster , resource_group_name , cluster_name , kube_config , kube_context )
144144 deployment_name = (consts .ARC_UPDATE_PREFIX + cluster_name ).lower ()
145145 print (f"Checking arm template deployment '{ deployment_name } ' for '{ cluster_resource_id } ' "
146- f"which has agent version '{ agent_version } '" )
146+ f"which has agent version '{ agent_version } '" , flush = True )
147147
148148 client = cf_deployments (cmd .cli_ctx , subscription_id )
149149
@@ -167,7 +167,7 @@ def upgrade_vme(
167167 f"[{ timestamp } ] The current deployment { deployment_name } is for { deployment_agent_version } "
168168 f"instead of current agent version { agent_version } . { consts .UPGRADE_NOTSTARTED_MSG } "
169169 )
170- print (msg )
170+ print (msg , flush = True )
171171 time .sleep (consts .UPGRADE_CHECK_INTERVAL )
172172 continue
173173 if utils .check_deployment_status (resources , deployment , timestamp ):
0 commit comments