You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airflow.apache.org by po...@apache.org on 2020/10/19 07:54:58 UTC
[airflow] branch master updated: fix cloudwatch and wasb
taskhandler log path config (#11650)
This is an automated email from the ASF dual-hosted git repository.
potiuk pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/airflow.git
The following commit(s) were added to refs/heads/master by this push:
new 86725f4 fix cloudwatch and wasb taskhandler log path config (#11650)
86725f4 is described below
commit 86725f481542aeb11c4433070b9939bd140b586e
Author: Ephraim Anierobi <sp...@gmail.com>
AuthorDate: Mon Oct 19 08:51:29 2020 +0100
fix cloudwatch and wasb taskhandler log path config (#11650)
---
airflow/config_templates/airflow_local_settings.py | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/airflow/config_templates/airflow_local_settings.py b/airflow/config_templates/airflow_local_settings.py
index 4b5d7f4..67c5444 100644
--- a/airflow/config_templates/airflow_local_settings.py
+++ b/airflow/config_templates/airflow_local_settings.py
@@ -186,7 +186,7 @@ if REMOTE_LOGGING:
elif REMOTE_BASE_LOG_FOLDER.startswith('cloudwatch://'):
CLOUDWATCH_REMOTE_HANDLERS: Dict[str, Dict[str, str]] = {
'task': {
- 'class': 'airflow.utils.log.cloudwatch_task_handler.CloudwatchTaskHandler',
+ 'class': 'airflow.providers.amazon.aws.log.cloudwatch_task_handler.CloudwatchTaskHandler',
'formatter': 'airflow',
'base_log_folder': str(os.path.expanduser(BASE_LOG_FOLDER)),
'log_group_arn': urlparse(REMOTE_BASE_LOG_FOLDER).netloc,
@@ -212,7 +212,7 @@ if REMOTE_LOGGING:
elif REMOTE_BASE_LOG_FOLDER.startswith('wasb'):
WASB_REMOTE_HANDLERS: Dict[str, Dict[str, Union[str, bool]]] = {
'task': {
- 'class': 'airflow.utils.log.wasb_task_handler.WasbTaskHandler',
+ 'class': 'airflow.providers.microsoft.azure.log.wasb_task_handler.WasbTaskHandler',
'formatter': 'airflow',
'base_log_folder': str(os.path.expanduser(BASE_LOG_FOLDER)),
'wasb_log_folder': REMOTE_BASE_LOG_FOLDER,