#NEWLINE# def test_scheduler_multiprocessing( self ) : #NEWLINE# #INDENT# '\n        Test that the scheduler can successfully queue multiple dags in parallel\n        ' #NEWLINE# dag_ids = [ 'test_start_date_scheduling' , 'test_dagrun_states_success' ] #NEWLINE# for dag_id in dag_ids : #NEWLINE# #INDENT# dag = self . dagbag . get_dag ( dag_id ) #NEWLINE# dag . clear ( ) #NEWLINE# #UNINDENT# scheduler = SchedulerJob ( dag_ids = session , num_runs = 2 ) #NEWLINE# scheduler . run ( ) #NEWLINE# dag_id = 'test_start_date_scheduling' #NEWLINE# session = settings . Session ( ) #NEWLINE# self . assertEqual ( len ( session . query ( TI ) . filter ( ( TI . dag_id == dag_id ) ) . all ( ) ) , 0 )