diff --git a/tests/models/test_dagrun.py b/tests/models/test_dagrun.py index 91dc596cc7850..ec9b64ce9ebc8 100644 --- a/tests/models/test_dagrun.py +++ b/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)