Fix pytests

Author: jscheffl

airflow-core/tests/unit/jobs/test_scheduler_job.py

@@ -4634,6 +4634,7 @@ def test_max_active_runs_in_a_dag_doesnt_prevent_backfill_from_running_catchup_t
             to_date=to_date,
             max_active_runs=3,
             reverse=False,
+            triggering_user="test_user",
             dag_run_conf={},
         )
         dag1_running_count = (
@@ -4738,6 +4739,7 @@ def test_max_active_runs_in_a_dag_doesnt_prevent_backfill_from_running_catchup_f
             to_date=to_date,
             max_active_runs=3,
             reverse=False,
+            triggering_user="test_user",
             dag_run_conf={},
         )
 
@@ -4813,6 +4815,7 @@ def _running_counts():
             to_date=to_date,
             max_active_runs=3,
             reverse=False,
+            triggering_user="test_user",
             dag_run_conf={},
         )
         dag1_non_b_running, dag1_b_running, total_running = _running_counts()
@@ -4928,6 +4931,7 @@ def _running_counts():
             to_date=to_date,
             max_active_runs=3,
             reverse=False,
+            triggering_user="test_user",
             dag_run_conf={},
         )
         dag1_non_b_running, dag1_b_running, total_running = _running_counts()
@@ -5034,6 +5038,7 @@ def _running_counts():
             to_date=to_date,
             max_active_runs=3,
             reverse=False,
+            triggering_user="test_user",
             dag_run_conf={},
         )
         dag1_non_b_running, dag1_b_running, total_running = _running_counts()
@@ -5182,6 +5187,7 @@ def _running_counts():
             to_date=to_date,
             max_active_runs=3,
             reverse=False,
+            triggering_user="test_user",
             dag_run_conf={},
         )
         dag1_non_b_running, dag1_b_running, total_running = _running_counts()
@@ -6654,6 +6660,7 @@ def test_mark_backfills_completed(dag_maker, session):
         to_date=pendulum.parse("2021-01-03"),
         max_active_runs=10,
         reverse=False,
+        triggering_user="test_user",
         dag_run_conf={},
     )
     session.expunge_all()

airflow-core/tests/unit/models/test_backfill.py

@@ -88,6 +88,7 @@ def test_reverse_and_depends_on_past_fails(dep_on_past, dag_maker, session):
             to_date=pendulum.parse("2021-01-05"),
             max_active_runs=2,
             reverse=True,
+            triggering_user="pytest",
             dag_run_conf={},
         )
     if dep_on_past:
@@ -124,6 +125,7 @@ def test_create_backfill_simple(reverse, existing, dag_maker, session):
         to_date=pendulum.parse("2021-01-05"),
         max_active_runs=2,
         reverse=reverse,
+        triggering_user="pytest",
         dag_run_conf=expected_run_conf,
     )
     query = (
@@ -189,6 +191,7 @@ def test_create_backfill_clear_existing_bundle_version(dag_maker, session):
         max_active_runs=10,
         reverse=False,
         dag_run_conf=None,
+        triggering_user="pytest",
         reprocess_behavior=ReprocessBehavior.FAILED,
     )
     session.commit()
@@ -277,6 +280,7 @@ def test_reprocess_behavior(reprocess_behavior, num_in_b, exc_reasons, dag_maker
         max_active_runs=2,
         reprocess_behavior=reprocess_behavior,
         reverse=False,
+        triggering_user="pytest",
         dag_run_conf=None,
     )
 
@@ -318,6 +322,7 @@ def test_params_stored_correctly(dag_maker, session):
         to_date=pendulum.parse("2021-01-05"),
         max_active_runs=263,
         reverse=False,
+        triggering_user="pytest",
         dag_run_conf={"this": "param"},
     )
     session.expunge_all()
@@ -343,6 +348,7 @@ def test_active_dag_run(dag_maker, session):
         to_date=pendulum.parse("2021-01-05"),
         max_active_runs=10,
         reverse=False,
+        triggering_user="pytest",
         dag_run_conf={"this": "param"},
     )
     assert b1 is not None
@@ -353,6 +359,7 @@ def test_active_dag_run(dag_maker, session):
             to_date=pendulum.parse("2021-02-05"),
             max_active_runs=10,
             reverse=False,
+            triggering_user="pytest",
             dag_run_conf={"this": "param"},
         )
 
@@ -483,5 +490,6 @@ def test_depends_on_past_requires_reprocess_failed(dep_on_past, behavior, dag_ma
             max_active_runs=5,
             reverse=False,
             dag_run_conf={},
+            triggering_user="pytest",
             reprocess_behavior=behavior,
         )