loop scheduler before running dag in docker tests (#45262)

apache · Dec 28, 2024 · a22faa5 · a22faa5
1 parent 6020a26
commit a22faa5
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/docker_tests/test_docker_compose_quick_start.py b/docker_tests/test_docker_compose_quick_start.py
@@ -98,6 +98,7 @@ def test_trigger_dag_and_wait_for_result(default_docker_image, tmp_path_factory,
     compose.down(remove_orphans=True, volumes=True, quiet=True)
     try:
         compose.up(detach=True, wait=True, color=not os.environ.get("NO_COLOR"))
+        compose.execute(service="airflow-scheduler", command=["airflow", "scheduler", "-n", "50"])
 
         api_request("PATCH", path=f"dags/{DAG_ID}", json={"is_paused": False})
         api_request("POST", path=f"dags/{DAG_ID}/dagRuns", json={"dag_run_id": DAG_RUN_ID})