#NEWLINE# def _delete_tenants( self ) : #NEWLINE# #INDENT# threads = self . config [ 'resource_management_workers' ] #NEWLINE# self . _remove_associated_networks ( ) #NEWLINE# def publish( queue ) : #NEWLINE# #INDENT# for tenant_id in self . context [ 'tenants' ] : #NEWLINE# #INDENT# queue . append ( tenant_id ) #NEWLINE# #UNINDENT# #UNINDENT# broker . run ( publish , self . _get_consumer_for_deletion ( 'delete_project' ) , threads ) #NEWLINE# self . context [ 'tenants' ] = { #NEWLINE# #INDENT# #NEWLINE# #UNINDENT# }