[GitHub] [airflow] Taragolis commented on a diff in pull request #34119: Make sure that only valid elasticsearch keys are passed to handler

2023-09-05 Thread via GitHub
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

[GitHub] [airflow] Taragolis commented on a diff in pull request #34119: Make sure that only valid elasticsearch keys are passed to handler

2023-09-05 Thread via GitHub
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

[GitHub] [airflow] Taragolis commented on a diff in pull request #34119: Make sure that only valid elasticsearch keys are passed to handler

2023-09-05 Thread via GitHub
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

[GitHub] [airflow] Taragolis commented on a diff in pull request #34119: Make sure that only valid elasticsearch keys are passed to handler

2023-09-05 Thread via GitHub
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

[GitHub] [airflow] Taragolis commented on a diff in pull request #34119: Make sure that only valid elasticsearch keys are passed to handler

2023-09-05 Thread via GitHub
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