#NEWLINE# def setUp( self ) : #NEWLINE# #INDENT# locator_mock = None #NEWLINE# self . cfg_manager = ConfigurationManager . ConfigurationManager ( ) #NEWLINE# self . cfg_manager . append_module ( configuration_module ) #NEWLINE# self . cfg_manager . _set_value ( COORDINATOR_LABORATORY_SERVERS , { #NEWLINE# #INDENT# 'lab1:inst@machine' : { #NEWLINE# #INDENT# 'inst1|exp1|cat1' : 'res_inst1@res_type' , #NEWLINE# #UNINDENT# } , #NEWLINE# 'lab2:inst@machine' : { #NEWLINE# #INDENT# 'inst2|exp1|cat1' : 'res_inst2@res_type' , #NEWLINE# #UNINDENT# } , #NEWLINE# #UNINDENT# } ) #NEWLINE# scheduling_systems = { #NEWLINE# #INDENT# 'res_type' : ( 'PRIORITY_QUEUE' , { #NEWLINE# #INDENT# 'randomize_instances' : False , #NEWLINE# #UNINDENT# } ) , #NEWLINE# #UNINDENT# } #NEWLINE# self . cfg_manager . _set_value ( 'core_scheduling_systems' , scheduling_systems ) #NEWLINE# self . coordinator = self . WrappedCoordinator ( locator_mock , self . cfg_manager , ConfirmerClass = SlowConfirmerMock ) #NEWLINE# self . coordinator . _clean ( ) #NEWLINE# self . coordinator . add_experiment_instance_id ( 'lab1:inst@machine' , ExperimentInstanceId ( 'inst1' , 'exp1' , 'cat1' ) , Resource ( 'res_type' , 'res_inst1' ) )