This is an automated email from the ASF dual-hosted git repository.
shahar 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 1f8b397beef fix mypy unreachable code warnings for elasticsearch
provider (#53464)
1f8b397beef is described below
commit 1f8b397beef255cbd0ac06a12b68918cd560a0c0
Author: Yunchi Pang <[email protected]>
AuthorDate: Sat Jul 19 08:20:05 2025 -0700
fix mypy unreachable code warnings for elasticsearch provider (#53464)
---
.../src/airflow/providers/elasticsearch/log/es_task_handler.py | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/providers/elasticsearch/src/airflow/providers/elasticsearch/log/es_task_handler.py
b/providers/elasticsearch/src/airflow/providers/elasticsearch/log/es_task_handler.py
index 4f8a6f59782..85a4e03b113 100644
---
a/providers/elasticsearch/src/airflow/providers/elasticsearch/log/es_task_handler.py
+++
b/providers/elasticsearch/src/airflow/providers/elasticsearch/log/es_task_handler.py
@@ -185,7 +185,7 @@ class ElasticsearchTaskHandler(FileTaskHandler,
ExternalLoggingMixin, LoggingMix
)
self.formatter: logging.Formatter
- self.handler: logging.FileHandler | logging.StreamHandler
+ self.handler: logging.FileHandler | logging.StreamHandler | None = None
self._doc_type_map: dict[Any, Any] = {}
self._doc_type: list[Any] = []
