#NEWLINE# @ cpo . event_wrapper ( True , step = utils . start_process_event_message ( 'StormMaster' ) ) #NEWLINE# def _start_storm_master( self , sm_instance ) : #NEWLINE# #INDENT# with remote . get_remote ( sm_instance ) as r : #NEWLINE# #INDENT# run . start_storm_nimbus_and_ui ( r ) #NEWLINE# LOG . info ( _LI ( 'Storm master at {host} has been started' ) . format ( host = sm_instance . hostname ( ) ) )