#NEWLINE# def _delete_envs( self ) : #NEWLINE# #INDENT# threads = self . config [ 'resource_management_workers' ] #NEWLINE# def publish( queue ) : #NEWLINE# #INDENT# queue . extend ( self . context [ 'fuel' ] [ 'environments' ] ) #NEWLINE# #UNINDENT# def consume( cache , env_id ) : #NEWLINE# #INDENT# self . fscenario . _delete_environment ( env_id ) #NEWLINE# #UNINDENT# broker . run ( self , consume , threads ) #NEWLINE# self . context [ 'fuel' ] = { #NEWLINE# #INDENT# #NEWLINE# #UNINDENT# }