'Test that the scheduler can successfully queue multiple dags in parallel'

def test_scheduler_multiprocessing(self):

    dag_ids = [u'test_start_date_scheduling', u'test_dagrun_states_success']
    for dag_id in dag_ids:
        dag = self.dagbag.get_dag(dag_id)
        dag.clear()
    scheduler = SchedulerJob(dag_ids=dag_ids, file_process_interval=0, processor_poll_interval=0.5, num_runs=2)
    scheduler.run()
    dag_id = u'test_start_date_scheduling'
    session = settings.Session()
    self.assertEqual(len(session.query(TI).filter((TI.dag_id == dag_id)).all()), 0)
