#NEWLINE# def _create_envs( self ) : #NEWLINE# #INDENT# threads = self . config [ 'resource_management_workers' ] #NEWLINE# envs = collections . deque ( ) #NEWLINE# def publish( queue ) : #NEWLINE# #INDENT# kwargs = { #NEWLINE# #INDENT# 'release_id' : self . config [ 'release_id' ] , #NEWLINE# 'network_provider' : self . config [ 'network_provider' ] , #NEWLINE# 'deployment_mode' : self . config [ 'deployment_mode' ] , #NEWLINE# 'net_segment_type' : self . config [ 'net_segment_type' ] , #NEWLINE# #UNINDENT# } #NEWLINE# for i in range ( self . config [ 'environments' ] ) : #NEWLINE# #INDENT# queue . append ( kwargs ) #NEWLINE# #UNINDENT# #UNINDENT# def consume( cache , kwargs ) : #NEWLINE# #INDENT# env_id = self . fscenario . _create_environment ( ** kwargs ) #NEWLINE# envs . append ( env_id ) #NEWLINE# #UNINDENT# broker . run ( publish , consume , threads ) #NEWLINE# return list ( envs )