#NEWLINE# @ cpo . event_wrapper ( True , step = _ ( 'Decommission nodes' ) , param = ( 'cluster' , 1 ) ) #NEWLINE# def decommission_nodes( self , cluster , process , role_names ) : #NEWLINE# #INDENT# service = self . get_service_by_role ( process , cluster ) #NEWLINE# service . decommission ( * role_names ) . wait ( ) #NEWLINE# for role_name in role_names : #NEWLINE# #INDENT# service . delete_role ( self )