Taragolis commented on code in PR #34119:
URL: https://github.com/apache/airflow/pull/34119#discussion_r1316410423
##
airflow/providers/elasticsearch/log/es_task_handler.py:
##
@@ -56,6 +58,18 @@
USE_PER_RUN_LOG_ID = hasattr(DagRun, "get_log_template")
+VALID_ES_CONFIG_KEYS
Taragolis commented on code in PR #34119:
URL: https://github.com/apache/airflow/pull/34119#discussion_r1316405846
##
airflow/providers/elasticsearch/log/es_task_handler.py:
##
@@ -56,6 +58,18 @@
USE_PER_RUN_LOG_ID = hasattr(DagRun, "get_log_template")
+VALID_ES_CONFIG_KEYS
Taragolis commented on code in PR #34119:
URL: https://github.com/apache/airflow/pull/34119#discussion_r1316403711
##
airflow/providers/elasticsearch/log/es_task_handler.py:
##
@@ -56,6 +58,18 @@
USE_PER_RUN_LOG_ID = hasattr(DagRun, "get_log_template")
+VALID_ES_CONFIG_KEYS
Taragolis commented on code in PR #34119:
URL: https://github.com/apache/airflow/pull/34119#discussion_r1316364199
##
airflow/providers/elasticsearch/log/es_task_handler.py:
##
@@ -56,6 +57,23 @@
USE_PER_RUN_LOG_ID = hasattr(DagRun, "get_log_template")
+# These are the only
Taragolis commented on code in PR #34119:
URL: https://github.com/apache/airflow/pull/34119#discussion_r1316345822
##
airflow/providers/elasticsearch/log/es_task_handler.py:
##
@@ -56,6 +57,23 @@
USE_PER_RUN_LOG_ID = hasattr(DagRun, "get_log_template")
+# These are the only