#NEWLINE# def _fetch_server( self , task_classes ) : #NEWLINE# #INDENT# endpoints = [ ] #NEWLINE# for cls in task_classes : #NEWLINE# #INDENT# endpoints . append ( endpoint . Endpoint ( cls ) ) #NEWLINE# #UNINDENT# server = worker_server . Server ( TEST_TOPIC , TEST_EXCHANGE , futurist . ThreadPoolExecutor ( max_workers = 1 ) , endpoints , transport = 'memory' , transport_options = { #NEWLINE# #INDENT# 'polling_interval' : POLLING_INTERVAL , #NEWLINE# #UNINDENT# } ) #NEWLINE# server_thread = threading_utils . daemon_thread ( server . start ) #NEWLINE# return ( server , server_thread )