This is an automated email from the ASF dual-hosted git repository.
jscheffl 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 0a17181065d Add unpause dag for trigger_dag method (#64694)
0a17181065d is described below
commit 0a17181065d5167241ae2aa72cd2a99ec13309d1
Author: Przemysław Mirowski <[email protected]>
AuthorDate: Fri Apr 3 22:58:00 2026 +0200
Add unpause dag for trigger_dag method (#64694)
---
airflow-e2e-tests/tests/airflow_e2e_tests/e2e_test_utils/clients.py | 3 +++
1 file changed, 3 insertions(+)
diff --git
a/airflow-e2e-tests/tests/airflow_e2e_tests/e2e_test_utils/clients.py
b/airflow-e2e-tests/tests/airflow_e2e_tests/e2e_test_utils/clients.py
index b3e70973b2e..ddbb642cf4f 100644
--- a/airflow-e2e-tests/tests/airflow_e2e_tests/e2e_test_utils/clients.py
+++ b/airflow-e2e-tests/tests/airflow_e2e_tests/e2e_test_utils/clients.py
@@ -114,8 +114,11 @@ class AirflowClient:
)
def trigger_dag(self, dag_id: str, json=None):
+ self.un_pause_dag(dag_id)
+
if json is None:
json = {}
+
return self._make_request(method="POST",
endpoint=f"dags/{dag_id}/dagRuns", json=json)
def wait_for_dag_run(self, dag_id: str, run_id: str, timeout=300,
check_interval=5):
