#NEWLINE# def __init__( self , generic_scheduler_arguments , experiment_id , schedulers , particular_configuration ) : #NEWLINE# #INDENT# super ( IndependentSchedulerAggregator , self ) . __init__ ( local_schedulers ) #NEWLINE# if ( len ( schedulers ) == 0 ) : #NEWLINE# #INDENT# raise NoSchedulerFoundError ( 'No scheduler provider at IndependentSchedulerAggregator' ) #NEWLINE# #UNINDENT# remote_schedulers = [ ] #NEWLINE# local_schedulers = [ ] #NEWLINE# for resource_type_name in schedulers : #NEWLINE# #INDENT# scheduler = schedulers [ resource_type_name ] #NEWLINE# if scheduler . is_remote ( ) : #NEWLINE# #INDENT# remote_schedulers . append ( resource_type_name ) #NEWLINE# #UNINDENT# else : #NEWLINE# #INDENT# local_schedulers . append ( resource_type_name ) #NEWLINE# #UNINDENT# #UNINDENT# self . ordered_schedulers = ( local_schedulers + remote_schedulers ) #NEWLINE# self . experiment_id = experiment_id #NEWLINE# self . schedulers = schedulers #NEWLINE# self . particular_configuration = particular_configuration