You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airflow.apache.org by sh...@apache.org on 2025/07/19 15:20:12 UTC
(airflow) branch main updated: fix mypy unreachable code warnings for elasticsearch provider (#53464)
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 <yu...@gmail.com>
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] = []