From c6cf9ae764fee205343a2ad8feeb731c6baf680f Mon Sep 17 00:00:00 2001 From: Pere Miquel Brull Date: Thu, 19 Jan 2023 12:49:18 +0100 Subject: [PATCH] Fix region name (#9811) --- ingestion/src/metadata/ingestion/sink/elasticsearch.py | 5 +---- 1 file changed, 1 insertion(+), 4 deletions(-) diff --git a/ingestion/src/metadata/ingestion/sink/elasticsearch.py b/ingestion/src/metadata/ingestion/sink/elasticsearch.py index 3f4e80c22af..4a4ead7a115 100644 --- a/ingestion/src/metadata/ingestion/sink/elasticsearch.py +++ b/ingestion/src/metadata/ingestion/sink/elasticsearch.py @@ -213,10 +213,7 @@ class ElasticsearchSink(Sink[Entity]): if self.config.use_AWS_credentials: credentials = boto3.Session().get_credentials() # We are initializing the Session() here and letting it pick up host creds. - # Not marked as a callable function, but a class. - region_from_boto3 = ( - boto3.Session().region_name() # pylint: disable=not-callable - ) + region_from_boto3 = boto3.Session().region_name http_auth = AWS4Auth( region=self.config.region_name if self.config.region_name