#NEWLINE# def run( self , **kwargs ) : #NEWLINE# #INDENT# dst_compute = self . cloud . resources [ utils . COMPUTE_RESOURCE ] #NEWLINE# for vm_id in dst_compute . failed_instances : #NEWLINE# #INDENT# dst_compute . force_delete_vm_by_id ( vm_id ) #NEWLINE# #UNINDENT# failed_instances = dst_compute . failed_instances #NEWLINE# if failed_instances : #NEWLINE# #INDENT# LOG . warning ( 'During deployment some instances were failed and redeployed with keeping wrong copies which should be deleted; the ids: %s' , self )