update version to 2.9.0

Author: cnfait

deploy.sh

@@ -7,7 +7,7 @@ underline=$(tput smul)
 notunderline=$(tput rmul)
 notbold=$(tput sgr0)
 
-version () { echo "awssdlf/2.8.0"; }
+version () { echo "awssdlf/2.9.0"; }
 
 usage () { echo "
     --version -- Prints the SDLF version

sdlf-cicd/deploy-generic.sh

@@ -10,7 +10,7 @@ die() {
     exit 1
 }
 
-version () { echo "awssdlf/2.8.0"; }
+version () { echo "awssdlf/2.9.0"; }
 
 usage () { echo "
 Serverless Data Lake Framework (SDLF) is a collection of infrastructure-as-code artifacts to deploy data architectures on AWS.

sdlf-datalakeLibrary/python/datalake_library/interfaces/dynamo_interface.py

@@ -7,6 +7,7 @@
 import boto3
 from boto3.dynamodb.conditions import Attr, Key
 from boto3.dynamodb.types import TypeSerializer
+from botocore.client import Config
 from botocore.exceptions import ClientError
 
 from ..commons import deserialize_dynamodb_item, init_logger, serialize_dynamodb_item
@@ -25,7 +26,8 @@ class DynamoInterface:
     def __init__(self, configuration, log_level=None, dynamodb_client=None):
         self.log_level = log_level or os.getenv("LOG_LEVEL", "INFO")
         self._logger = init_logger(__name__, self.log_level)
-        self.dynamodb_client = dynamodb_client or boto3.client("dynamodb")
+        session_config = Config(user_agent="awssdlf/2.9.0")
+        self.dynamodb_client = dynamodb_client or boto3.client("dynamodb", config=session_config)
 
         self._config = configuration
 

sdlf-datalakeLibrary/python/datalake_library/interfaces/s3_interface.py

@@ -16,7 +16,7 @@ class S3Interface:
     def __init__(self, log_level=None, s3_client=None):
         self.log_level = log_level or os.getenv("LOG_LEVEL", "INFO")
         self._logger = init_logger(__name__, self.log_level)
-        self._session_config = Config(user_agent="awssdlf/2.3.0")
+        self._session_config = Config(user_agent="awssdlf/2.9.0")
         self._s3_client = s3_client or boto3.client("s3", config=self._session_config)
 
     def download_object(self, bucket, key):

sdlf-datalakeLibrary/python/datalake_library/interfaces/sqs_interface.py

@@ -3,6 +3,7 @@
 import uuid
 
 import boto3
+from botocore.client import Config
 from botocore.exceptions import ClientError
 
 from ..commons import init_logger
@@ -13,7 +14,8 @@ def __init__(self, queue_name, log_level=None, sqs_client=None):
         self.log_level = log_level or os.getenv("LOG_LEVEL", "INFO")
         self._logger = init_logger(__name__, self.log_level)
         sqs_endpoint_url = "https://sqs." + os.getenv("AWS_REGION") + ".amazonaws.com"
-        self._sqs_client = sqs_client or boto3.client("sqs", endpoint_url=sqs_endpoint_url)
+        session_config = Config(user_agent="awssdlf/2.9.0")
+        self._sqs_client = sqs_client or boto3.client("sqs", endpoint_url=sqs_endpoint_url, config=session_config)
 
         self._message_queue = self._sqs_client.get_queue_url(QueueName=queue_name)["QueueUrl"]
 

sdlf-datalakeLibrary/python/datalake_library/interfaces/states_interface.py

@@ -3,6 +3,7 @@
 from datetime import date, datetime
 
 import boto3
+from botocore.client import Config
 
 from ..commons import init_logger
 
@@ -12,7 +13,10 @@ def __init__(self, log_level=None, states_client=None):
         self.log_level = log_level or os.getenv("LOG_LEVEL", "INFO")
         self._logger = init_logger(__name__, self.log_level)
         stepfunctions_endpoint_url = "https://states." + os.getenv("AWS_REGION") + ".amazonaws.com"
-        self._states_client = states_client or boto3.client("stepfunctions", endpoint_url=stepfunctions_endpoint_url)
+        session_config = Config(user_agent="awssdlf/2.9.0")
+        self._states_client = states_client or boto3.client(
+            "stepfunctions", endpoint_url=stepfunctions_endpoint_url, config=session_config
+        )
 
     @staticmethod
     def json_serial(obj):

sdlf-datalakeLibrary/python/datalake_library/sdlf/__version__.py

@@ -1,2 +1,2 @@
 __title__ = "SDLF"
-__version__ = "2.8.0"
+__version__ = "2.9.0"

sdlf-dataset/pyproject.toml

@@ -1,6 +1,6 @@
 [tool.poetry]
 name = "sdlf.dataset"
-version = "2.8.0"
+version = "2.9.0"
 description = "AWS Serverless Data Lake Framework"
 authors = ["Amazon Web Services"]
 license = "MIT-0"

sdlf-foundations/pyproject.toml

@@ -1,6 +1,6 @@
 [tool.poetry]
 name = "sdlf.foundations"
-version = "2.8.0"
+version = "2.9.0"
 description = "AWS Serverless Data Lake Framework"
 authors = ["Amazon Web Services"]
 license = "MIT-0"

sdlf-foundations/src/lambda/catalog/src/lambda_function.py

@@ -8,11 +8,11 @@
 from botocore.config import Config
 from botocore.exceptions import ClientError
 
-session_config = Config(user_agent_extra="awssdlf/2.8.0")
+session_config = Config(user_agent_extra="awssdlf/2.9.0")
 
 logger = logging.getLogger()
 logger.setLevel(logging.INFO)
-dynamodb = boto3.client("dynamodb")
+dynamodb = boto3.client("dynamodb", config=session_config)
 catalog_table = os.getenv("OBJECTMETADATA_TABLE")