#NEWLINE# def resolve_remote( self , deployables ) : #NEWLINE# #INDENT# all_desc_iters = dynops . List ( ) #NEWLINE# store = GlobalStore ( node = self . node ) #NEWLINE# for ( actor_name , info ) in deployables . iteritems ( ) : #NEWLINE# #INDENT# desc_iter = store . global_lookup_iter ( info [ 'signature' ] , info [ 'args' ] . keys ( ) ) #NEWLINE# all_desc_iters . append ( ( actor_name , desc_iter ) , trigger_iter = desc_iter ) #NEWLINE# #UNINDENT# all_desc_iters . final ( ) #NEWLINE# collect_desc_iter = dynops . Collect ( all_desc_iters ) . set_name ( 'collected_desc' ) #NEWLINE# select_iter = dynops . Map ( self . select_actor , collect_desc_iter , done = False , priority = { k : [ ] for k in self . deployable [ 'actors' ] . keys ( ) } , eager = True ) . set_name ( 'select_actor' ) #NEWLINE# select_iter . set_cb ( self . deploy_unhandled_actors , store ) #NEWLINE# self . deploy_unhandled_actors ( select_iter )