fix test_dagrun failures after merge

Author: xBis7

tests/models/test_dagrun.py

@@ -527,7 +527,7 @@ def test_start_dr_spans_if_needed_new_span(self, session):
             schedule=datetime.timedelta(days=1),
             start_date=datetime.datetime(2017, 1, 1),
         )
-        DAG.bulk_write_to_db(dags=[dag], processor_subdir="/tmp/test", session=session)
+        DAG.bulk_write_to_db(dags=[dag], session=session)
 
         dag_task1 = EmptyOperator(task_id="test_task1", dag=dag)
         dag_task2 = EmptyOperator(task_id="test_task2", dag=dag)
@@ -563,7 +563,7 @@ def test_start_dr_spans_if_needed_span_with_continuance(self, session):
             schedule=datetime.timedelta(days=1),
             start_date=datetime.datetime(2017, 1, 1),
         )
-        DAG.bulk_write_to_db(dags=[dag], processor_subdir="/tmp/test", session=session)
+        DAG.bulk_write_to_db(dags=[dag], session=session)
 
         dag_task1 = EmptyOperator(task_id="test_task1", dag=dag)
         dag_task2 = EmptyOperator(task_id="test_task2", dag=dag)
@@ -608,7 +608,7 @@ def test_end_dr_span_if_needed(self, session):
             schedule=datetime.timedelta(days=1),
             start_date=datetime.datetime(2017, 1, 1),
         )
-        DAG.bulk_write_to_db(dags=[dag], processor_subdir="/tmp/test", session=session)
+        DAG.bulk_write_to_db(dags=[dag], session=session)
 
         dag_task1 = EmptyOperator(task_id="test_task1", dag=dag)
         dag_task2 = EmptyOperator(task_id="test_task2", dag=dag)
@@ -648,7 +648,7 @@ def test_end_dr_span_if_needed_with_span_from_another_scheduler(self, session):
             schedule=datetime.timedelta(days=1),
             start_date=datetime.datetime(2017, 1, 1),
         )
-        DAG.bulk_write_to_db(dags=[dag], processor_subdir="/tmp/test", session=session)
+        DAG.bulk_write_to_db(dags=[dag], session=session)
 
         dag_task1 = EmptyOperator(task_id="test_task1", dag=dag)
         dag_task2 = EmptyOperator(task_id="test_task2", dag=dag)