From edf0af0d6d449a9de8ed0b762651e6d311ca3b82 Mon Sep 17 00:00:00 2001 From: Pankaj Date: Sun, 21 Apr 2024 22:23:28 +0530 Subject: [PATCH] Fix --- airflow/config_templates/pre_2_7_defaults.cfg | 1 - airflow/providers/elasticsearch/log/es_task_handler.py | 2 +- 2 files changed, 1 insertion(+), 2 deletions(-) diff --git a/airflow/config_templates/pre_2_7_defaults.cfg b/airflow/config_templates/pre_2_7_defaults.cfg index e9235bb74bd65c..2568d42445f80c 100644 --- a/airflow/config_templates/pre_2_7_defaults.cfg +++ b/airflow/config_templates/pre_2_7_defaults.cfg @@ -76,7 +76,6 @@ json_fields = asctime, filename, lineno, levelname, message host_field = host offset_field = offset index_patterns = _all -index_patterns_callable = [elasticsearch_configs] use_ssl = False diff --git a/airflow/providers/elasticsearch/log/es_task_handler.py b/airflow/providers/elasticsearch/log/es_task_handler.py index 766a3b6229a8c5..923b92511f0d13 100644 --- a/airflow/providers/elasticsearch/log/es_task_handler.py +++ b/airflow/providers/elasticsearch/log/es_task_handler.py @@ -154,7 +154,7 @@ def __init__( host: str = "http://localhost:9200", frontend: str = "localhost:5601", index_patterns: str = conf.get("elasticsearch", "index_patterns"), - index_patterns_callable: str = conf.get("elasticsearch", "index_patterns_callable"), + index_patterns_callable: str = conf.get("elasticsearch", "index_patterns_callable", fallback=""), es_kwargs: dict | None | Literal["default_es_kwargs"] = "default_es_kwargs", *, filename_template: str | None = None,