Fix parameter alignment in CustomStorage method calls

Align continuation parameters under the opening parenthesis of
PutObject, SearchObjects, and GetObject calls to match Python
convention and the pre-existing style in this codebase.

Author: mraible

functions/csv-import/main.py

@@ -268,8 +268,8 @@ def _process_batch(batch_context: Dict[str, Any]) -> Dict[str, int]:
     for record in batch:
         try:
             response = custom_storage.PutObject(body=record,
-                                            collection_name=collection_name,
-                                            object_key=record["event_id"])
+                                              collection_name=collection_name,
+                                              object_key=record["event_id"])
 
             if response["status_code"] == 200:
                 success_count += 1

functions/log-event/main.py

@@ -52,8 +52,8 @@ def on_post(request: Request) -> Response:
         collection_name = "event_logs"
 
         response = custom_storage.PutObject(body=json_data,
-                                        collection_name=collection_name,
-                                        object_key=event_id)
+                                          collection_name=collection_name,
+                                          object_key=event_id)
 
         if response["status_code"] != 200:
             error_message = response.get("error", {}).get("message", "Unknown error")
@@ -67,8 +67,8 @@ def on_post(request: Request) -> Response:
 
         # Query the collection to retrieve the event by id
         query_response = custom_storage.SearchObjects(filter=f"event_id:'{event_id}'",
-                                                  collection_name=collection_name,
-                                                  limit=5)
+                                                     collection_name=collection_name,
+                                                     limit=5)
 
         return Response(
             body={

functions/process-events/main.py

@@ -84,9 +84,9 @@ def _get_checkpoint(workflow_context: Dict[str, Any]) -> Dict[str, Any]:
 
     # Retrieve the most recent checkpoint for this workflow
     checkpoint_response = custom_storage.SearchObjects(filter=f"workflow_id:'{workflow_id}'",
-                                                   collection_name=checkpoint_collection,
-                                                   sort="last_processed_timestamp.desc",
-                                                   limit=1)
+                                                      collection_name=checkpoint_collection,
+                                                      sort="last_processed_timestamp.desc",
+                                                      limit=1)
 
     logger.debug(f"checkpoint response: {checkpoint_response}")
 
@@ -98,7 +98,7 @@ def _get_checkpoint(workflow_context: Dict[str, Any]) -> Dict[str, Any]:
 
         # SearchObjects returns metadata, not actual objects, so use GetObject for details
         object_details = custom_storage.GetObject(collection_name=checkpoint_collection,
-                                              object_key=last_checkpoint["object_key"])
+                                               object_key=last_checkpoint["object_key"])
 
         # GetObject returns bytes; convert to JSON
         json_response = json.loads(object_details.decode("utf-8"))
@@ -142,8 +142,8 @@ def _process_and_update(workflow_context: Dict[str, Any], checkpoint_data: Dict[
     logger.debug(f"Sending data to PutObject: {checkpoint_update}")
 
     custom_storage.PutObject(body=checkpoint_update,
-                         collection_name=checkpoint_collection,
-                         object_key=f"checkpoint_{workflow_id}")
+                             collection_name=checkpoint_collection,
+                             object_key=f"checkpoint_{workflow_id}")
 
     return Response(
         body={