This is an automated email from the ASF dual-hosted git repository.
vincbeck 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 5f3ed2385d2 fix mypy type errors in opensearch provider for sqlalchemy
2 upgrade (#56819)
5f3ed2385d2 is described below
commit 5f3ed2385d2337ab93b4ad0220487082d8a8457f
Author: Zhen-Lun (Kevin) Hong <[email protected]>
AuthorDate: Tue Oct 21 00:25:42 2025 +0800
fix mypy type errors in opensearch provider for sqlalchemy 2 upgrade
(#56819)
---
.../airflow/providers/opensearch/log/os_task_handler.py | 14 +++++---------
1 file changed, 5 insertions(+), 9 deletions(-)
diff --git
a/providers/opensearch/src/airflow/providers/opensearch/log/os_task_handler.py
b/providers/opensearch/src/airflow/providers/opensearch/log/os_task_handler.py
index b3d4f98507e..bd3966743e0 100644
---
a/providers/opensearch/src/airflow/providers/opensearch/log/os_task_handler.py
+++
b/providers/opensearch/src/airflow/providers/opensearch/log/os_task_handler.py
@@ -309,15 +309,11 @@ class OpensearchTaskHandler(FileTaskHandler,
ExternalLoggingMixin, LoggingMixin)
data_interval_end = self._clean_date(dag_run.data_interval_end)
logical_date = self._clean_date(dag_run.logical_date)
else:
- if dag_run.data_interval_start:
- data_interval_start = dag_run.data_interval_start.isoformat()
- else:
- data_interval_start = ""
- if dag_run.data_interval_end:
- data_interval_end = dag_run.data_interval_end.isoformat()
- else:
- data_interval_end = ""
- logical_date = dag_run.logical_date.isoformat()
+ data_interval_start = (
+ dag_run.data_interval_start.isoformat() if
dag_run.data_interval_start else ""
+ )
+ data_interval_end = dag_run.data_interval_end.isoformat() if
dag_run.data_interval_end else ""
+ logical_date = dag_run.logical_date.isoformat() if
dag_run.logical_date else ""
return log_id_template.format(
dag_id=ti.dag_id,
task_id=ti.task_id,
