This is an automated email from the ASF dual-hosted git repository.
pierrejeambrun 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 cce2faf3a7c Fix clear dagrun endpoint (#45024)
cce2faf3a7c is described below
commit cce2faf3a7c90fb116e6aec55e99aa2b543ce843
Author: Pierre Jeambrun <[email protected]>
AuthorDate: Wed Dec 18 19:29:37 2024 +0800
Fix clear dagrun endpoint (#45024)
---
airflow/api_fastapi/core_api/routes/public/dag_run.py | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/airflow/api_fastapi/core_api/routes/public/dag_run.py
b/airflow/api_fastapi/core_api/routes/public/dag_run.py
index 2718186351c..5f0d89aad98 100644
--- a/airflow/api_fastapi/core_api/routes/public/dag_run.py
+++ b/airflow/api_fastapi/core_api/routes/public/dag_run.py
@@ -245,8 +245,8 @@ def clear_dag_run(
)
else:
dag.clear(
- start_date=dag_run.start_date,
- end_date=dag_run.end_date,
+ start_date=start_date,
+ end_date=end_date,
task_ids=None,
only_failed=False,
session=session,