Fix region name (#9811)

This commit is contained in:
Pere Miquel Brull 2023-01-19 12:49:18 +01:00 committed by GitHub
parent 3dcccb1f14
commit c6cf9ae764
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23

View File

@ -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