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 2539cb4 Move to watchtower 2.0.1 (#19907)
2539cb4 is described below
commit 2539cb44b47d78e81a88fde51087f4cc77c924c5
Author: Niko <[email protected]>
AuthorDate: Wed Dec 1 09:53:30 2021 -0800
Move to watchtower 2.0.1 (#19907)
- This version of watchtower contains patches that fixes #15279
where empty log lines would crash Watchtower.
---
airflow/providers/amazon/aws/log/cloudwatch_task_handler.py | 2 +-
setup.py | 2 +-
2 files changed, 2 insertions(+), 2 deletions(-)
diff --git a/airflow/providers/amazon/aws/log/cloudwatch_task_handler.py
b/airflow/providers/amazon/aws/log/cloudwatch_task_handler.py
index 634c4e0..e6f1925 100644
--- a/airflow/providers/amazon/aws/log/cloudwatch_task_handler.py
+++ b/airflow/providers/amazon/aws/log/cloudwatch_task_handler.py
@@ -81,7 +81,7 @@ class CloudwatchTaskHandler(FileTaskHandler, LoggingMixin):
self.handler = watchtower.CloudWatchLogHandler(
log_group=self.log_group,
stream_name=self._render_filename(ti, ti.try_number),
- boto3_session=self.hook.get_session(self.region_name),
+ boto3_client=self.hook.get_conn(),
)
def close(self):
diff --git a/setup.py b/setup.py
index e6d762b..29690dc 100644
--- a/setup.py
+++ b/setup.py
@@ -189,7 +189,7 @@ alibaba = [
]
amazon = [
'boto3>=1.15.0,<1.19.0',
- 'watchtower~=1.0.6',
+ 'watchtower~=2.0.1',
'jsonpath_ng>=1.5.3',
'redshift_connector~=2.0.888',
'sqlalchemy_redshift~=0.8.6',
