This is an automated email from the ASF dual-hosted git repository.
Lee-W pushed a commit to branch airflow-ctl/v0-1-test
in repository https://gitbox.apache.org/repos/asf/airflow.git
The following commit(s) were added to refs/heads/airflow-ctl/v0-1-test by this
push:
new b5f71b051b3 Fix airflowctl dags state crash from an incomplete
backport (#71095)
b5f71b051b3 is described below
commit b5f71b051b33fb8981ab68bb066ff478a5c8f5b2
Author: Wei Lee <[email protected]>
AuthorDate: Wed Aug 5 17:23:42 2026 +0800
Fix airflowctl dags state crash from an incomplete backport (#71095)
---
airflow-ctl/src/airflowctl/api/operations.py | 9 ++++++++-
1 file changed, 8 insertions(+), 1 deletion(-)
diff --git a/airflow-ctl/src/airflowctl/api/operations.py
b/airflow-ctl/src/airflowctl/api/operations.py
index bbfc18fce2c..c51d991fcfd 100644
--- a/airflow-ctl/src/airflowctl/api/operations.py
+++ b/airflow-ctl/src/airflowctl/api/operations.py
@@ -632,6 +632,8 @@ class DagRunOperations(BaseOperations):
logical_date_gte: datetime.datetime | None = None,
logical_date_lte: datetime.datetime | None = None,
order_by: str | None = None,
+ *,
+ suppress_error_log: bool = False,
) -> DAGRunCollectionResponse | ServerResponseError:
"""
List dag runs (at most `limit` results).
@@ -645,6 +647,7 @@ class DagRunOperations(BaseOperations):
logical_date_gte: Filter dag runs with a logical date greater than
or equal to this value.
logical_date_lte: Filter dag runs with a logical date less than or
equal to this value.
order_by: Order the results by the specified field.
+ suppress_error_log: Skip client-side error logging, for callers
handling the error themselves.
"""
# Use "~" for all DAGs if dag_id is not specified
if not dag_id:
@@ -661,7 +664,11 @@ class DagRunOperations(BaseOperations):
)
try:
- self.response = self.client.get(f"/dags/{dag_id}/dagRuns",
params=params)
+ self.response = self.client.get(
+ f"/dags/{dag_id}/dagRuns",
+ params=params,
+ extensions={"airflowctl_suppress_error_log":
suppress_error_log},
+ )
return
DAGRunCollectionResponse.model_validate_json(self.response.content)
except ServerResponseError as e:
raise e
