This is an automated email from the ASF dual-hosted git repository.

potiuk pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/airflow.git


The following commit(s) were added to refs/heads/main by this push:
     new a22faa5921b loop scheduler before running dag in docker tests (#45262)
a22faa5921b is described below

commit a22faa5921bd6b3fbb8a95f582f56da1cdf39fc5
Author: GPK <[email protected]>
AuthorDate: Sat Dec 28 13:13:30 2024 +0000

    loop scheduler before running dag in docker tests (#45262)
---
 docker_tests/test_docker_compose_quick_start.py | 1 +
 1 file changed, 1 insertion(+)

diff --git a/docker_tests/test_docker_compose_quick_start.py 
b/docker_tests/test_docker_compose_quick_start.py
index eab0a7a62e0..4b6335facff 100644
--- 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})

Reply via email to