#NEWLINE# def run( self , key ) : #NEWLINE# #INDENT# nkey = key . split ( 'fanout~' ) [ 1 : ] [ 0 ] #NEWLINE# if ( not self . _ring_has ( nkey ) ) : #NEWLINE# #INDENT# LOG . warn ( ( _ ( "No key defining hosts for topic '%s', see ringfile" ) % ( nkey , ) ) ) #NEWLINE# return [ ] #NEWLINE# #UNINDENT# return map ( ( lambda x : ( ( ( key + '.' ) + x ) , x ) ) , self . ring [ nkey ] )