This is an automated email from the ASF dual-hosted git repository.
potiuk 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 e034749cdb3 Fix max_lines_per_page config setting for
ElasticsearchRemoteLogIO (#62562)
e034749cdb3 is described below
commit e034749cdb3d27f5be02c6448eab928a3a9ea123
Author: stephen-bracken <[email protected]>
AuthorDate: Fri Feb 27 21:33:20 2026 +0000
Fix max_lines_per_page config setting for ElasticsearchRemoteLogIO (#62562)
---
.../src/airflow/providers/elasticsearch/log/es_task_handler.py | 3 +--
1 file changed, 1 insertion(+), 2 deletions(-)
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 3b5480ff60e..60080658ae9 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
@@ -157,7 +157,6 @@ class ElasticsearchTaskHandler(FileTaskHandler,
ExternalLoggingMixin, LoggingMix
"""
PAGE = 0
- MAX_LINE_PER_PAGE = conf.getint("elasticsearch", "max_lines_per_page",
fallback=1000)
LOG_NAME = "Elasticsearch"
trigger_should_wrap = True
@@ -578,7 +577,7 @@ class ElasticsearchRemoteLogIO(LoggingMixin): # noqa: D101
self.client = elasticsearch.Elasticsearch(self.host, **es_kwargs)
self.index_patterns_callable = conf.get("elasticsearch",
"index_patterns_callable", fallback="")
self.PAGE = 0
- self.MAX_LINE_PER_PAGE = 1000
+ self.MAX_LINE_PER_PAGE = conf.getint("elasticsearch",
"max_lines_per_page", fallback=1000)
self.index_patterns: str = conf.get("elasticsearch", "index_patterns")
self._doc_type_map: dict[Any, Any] = {}
self._doc_type: list[Any] = []
