#NEWLINE# def action( self ) : #NEWLINE# #INDENT# if ( not self . master_events . value ) : #NEWLINE# #INDENT# return #NEWLINE# #UNINDENT# events = [ ] #NEWLINE# for master in self . road_stack . value . remotes : #NEWLINE# #INDENT# master_uid = master #NEWLINE# #UNINDENT# while self . master_events . value : #NEWLINE# #INDENT# events . append ( self . master_events . value . popleft ( ) ) #NEWLINE# #UNINDENT# route = { #NEWLINE# #INDENT# 'src' : ( master . road_stack . value . local . name , None , None ) , #NEWLINE# 'dst' : ( next ( list ( self . road_stack . value . remotes . values ( ) ) ) . name , None , 'remote_cmd' ) , #NEWLINE# #UNINDENT# } #NEWLINE# load = { #NEWLINE# #INDENT# 'id' : self . opts . value [ 'id' ] , #NEWLINE# 'events' : events , #NEWLINE# 'cmd' : '_minion_event' , #NEWLINE# #UNINDENT# } #NEWLINE# self . road_stack . value . transmit ( { #NEWLINE# #INDENT# 'route' : route , #NEWLINE# 'load' : load , #NEWLINE# #UNINDENT# } , uid = master_uid )