def test_scheduler_multiprocessing(self):
        dag_ids = ['test_start_date_scheduling', '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, num_runs=2)
        scheduler.run()

        # zero tasks ran
        dag_id = 'test_start_date_scheduling'
        session = settings.Session()
        self.assertEqual(
            len(session.query(TI).filter(TI.dag_id == dag_id).all()), 0)
Test that the scheduler can successfully queue multiple dags in parallel
dataset/ETHPy150Open airbnb/airflow/tests/jobs.py/SchedulerJobTest.test_scheduler_multiprocessing