ruff format

Author: cnfait

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

@@ -388,7 +388,7 @@ def _remove_dup_pkeys_request_if_any(self, request: "WriteRequestTypeDef", overw
             if self._extract_pkey_values(item, overwrite_by_pkeys) == pkey_values_new:
                 self._items_buffer.remove(item)
                 self._logger.debug(
-                    "With overwrite_by_pkeys enabled, skipping " "request:%s",
+                    "With overwrite_by_pkeys enabled, skipping request:%s",
                     item,
                 )
 

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

@@ -49,7 +49,7 @@ def build_table_item(team, dataset, table):
     table_item["team"] = {"S": team}
     table_item["dataset"] = {"S": dataset}
     table_item["table"] = {"S": table["Name"]}
-    table_item["name"] = {"S": f"{team}-{dataset}-{table["Name"]}"}
+    table_item["name"] = {"S": f"{team}-{dataset}-{table['Name']}"}
     table_item["glue_table"] = {"S": table["Name"]}
     table_item["glue_database"] = {"S": table["DatabaseName"]}
     table_item["status"] = {"S": "ACTIVE"}

sdlf-monitoring/lambda/cloudwatchlogs-transformer/src/lambda_function.py

@@ -97,7 +97,7 @@ def lambda_handler(event, context):
 
         try:
             put_records(stream_name, records_to_reingest, 0, 20)
-            logger.info(f'Reingested {len(records_to_reingest)} records out of {len(event["records"])}')
+            logger.info(f"Reingested {len(records_to_reingest)} records out of {len(event['records'])}")
         except Exception as err:
             logger.info(f"Failed to reingest records. {str(err)}")
             raise err