This is an automated email from the ASF dual-hosted git repository.
uranusjr 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 04a6e850e7 Fix data interval in cli.dags.trigger command output
(#32548)
04a6e850e7 is described below
commit 04a6e850e7d4437fe93a60d713c1d82e8f23885f
Author: Hussein Awala <[email protected]>
AuthorDate: Wed Jul 12 10:35:33 2023 +0200
Fix data interval in cli.dags.trigger command output (#32548)
---
airflow/api/client/local_client.py | 4 ++--
tests/api_experimental/client/test_local_client.py | 4 ++--
2 files changed, 4 insertions(+), 4 deletions(-)
diff --git a/airflow/api/client/local_client.py
b/airflow/api/client/local_client.py
index afdcd0abd6..b90039608f 100644
--- a/airflow/api/client/local_client.py
+++ b/airflow/api/client/local_client.py
@@ -43,8 +43,8 @@ class Client(api_client.Client):
"conf": dag_run.conf,
"dag_id": dag_run.dag_id,
"dag_run_id": dag_run.run_id,
- "data_interval_end": dag_run.data_interval_start,
- "data_interval_start": dag_run.data_interval_end,
+ "data_interval_start": dag_run.data_interval_start,
+ "data_interval_end": dag_run.data_interval_end,
"end_date": dag_run.end_date,
"external_trigger": dag_run.external_trigger,
"last_scheduling_decision": dag_run.last_scheduling_decision,
diff --git a/tests/api_experimental/client/test_local_client.py
b/tests/api_experimental/client/test_local_client.py
index 5527f00dea..575400a115 100644
--- a/tests/api_experimental/client/test_local_client.py
+++ b/tests/api_experimental/client/test_local_client.py
@@ -147,8 +147,8 @@ class TestLocalClient:
"conf": {},
"dag_id": test_dag_id,
"dag_run_id": run_id,
- "data_interval_end": EXECDATE,
- "data_interval_start": EXECDATE + pendulum.duration(hours=1),
+ "data_interval_start": EXECDATE,
+ "data_interval_end": EXECDATE + pendulum.duration(hours=1),
"end_date": None,
"external_trigger": True,
"last_scheduling_decision": None,
