m

Author: Lucas McDonald

DynamoDbEncryption/runtimes/python/src/aws_dbesdk_dynamodb/smithygenerated/aws_cryptography_dbencryptionsdk_dynamodb/aws_sdk_to_dafny.py

@@ -25,7 +25,9 @@ def com_amazonaws_dynamodb_AttributeValue(native_input):
                 "".join(
                     [
                         chr(int.from_bytes(pair, "big"))
-                        for pair in zip(*[iter(native_input["S"].encode("utf-16-be"))] * 2)
+                        for pair in zip(
+                            *[iter(native_input["S"].encode("utf-16-be"))] * 2
+                        )
                     ]
                 )
             )
@@ -36,7 +38,9 @@ def com_amazonaws_dynamodb_AttributeValue(native_input):
                 "".join(
                     [
                         chr(int.from_bytes(pair, "big"))
-                        for pair in zip(*[iter(native_input["N"].encode("utf-16-be"))] * 2)
+                        for pair in zip(
+                            *[iter(native_input["N"].encode("utf-16-be"))] * 2
+                        )
                     ]
                 )
             )
@@ -51,7 +55,9 @@ def com_amazonaws_dynamodb_AttributeValue(native_input):
                         "".join(
                             [
                                 chr(int.from_bytes(pair, "big"))
-                                for pair in zip(*[iter(list_element.encode("utf-16-be"))] * 2)
+                                for pair in zip(
+                                    *[iter(list_element.encode("utf-16-be"))] * 2
+                                )
                             ]
                         )
                     )
@@ -67,7 +73,9 @@ def com_amazonaws_dynamodb_AttributeValue(native_input):
                         "".join(
                             [
                                 chr(int.from_bytes(pair, "big"))
-                                for pair in zip(*[iter(list_element.encode("utf-16-be"))] * 2)
+                                for pair in zip(
+                                    *[iter(list_element.encode("utf-16-be"))] * 2
+                                )
                             ]
                         )
                     )
@@ -76,14 +84,19 @@ def com_amazonaws_dynamodb_AttributeValue(native_input):
             )
         )
     elif "BS" in native_input.keys():
-        AttributeValue_union_value = AttributeValue_BS(Seq([Seq(list_element) for list_element in native_input["BS"]]))
+        AttributeValue_union_value = AttributeValue_BS(
+            Seq([Seq(list_element) for list_element in native_input["BS"]])
+        )
     elif "M" in native_input.keys():
         AttributeValue_union_value = AttributeValue_M(
             Map(
                 {
                     Seq(
                         "".join(
-                            [chr(int.from_bytes(pair, "big")) for pair in zip(*[iter(key.encode("utf-16-be"))] * 2)]
+                            [
+                                chr(int.from_bytes(pair, "big"))
+                                for pair in zip(*[iter(key.encode("utf-16-be"))] * 2)
+                            ]
                         )
                     ): aws_cryptography_internal_dynamodb.smithygenerated.com_amazonaws_dynamodb.aws_sdk_to_dafny.com_amazonaws_dynamodb_AttributeValue(
                         value
@@ -108,6 +121,8 @@ def com_amazonaws_dynamodb_AttributeValue(native_input):
     elif "BOOL" in native_input.keys():
         AttributeValue_union_value = AttributeValue_BOOL(native_input["BOOL"])
     else:
-        raise ValueError("No recognized union value in union type: " + str(native_input))
+        raise ValueError(
+            "No recognized union value in union type: " + str(native_input)
+        )
 
     return AttributeValue_union_value

DynamoDbEncryption/runtimes/python/src/aws_dbesdk_dynamodb/smithygenerated/aws_cryptography_dbencryptionsdk_dynamodb/client.py

@@ -107,7 +107,9 @@ def _execute_operation(
         operation_name: str,
     ) -> Output:
         try:
-            return self._handle_execution(input, plugins, serialize, deserialize, config, operation_name)
+            return self._handle_execution(
+                input, plugins, serialize, deserialize, config, operation_name
+            )
         except Exception as e:
             # Make sure every exception that we throw is an instance of ServiceError so
             # customers can reliably catch everything we throw.
@@ -171,7 +173,9 @@ def _handle_execution(
                 interceptor.read_before_serialization(context)
 
             # Step 4: Serialize the request
-            context_with_transport_request = cast(InterceptorContext[Input, None, DafnyRequest, None], context)
+            context_with_transport_request = cast(
+                InterceptorContext[Input, None, DafnyRequest, None], context
+            )
             context_with_transport_request._transport_request = serialize(
                 context_with_transport_request.request, config
             )
@@ -182,8 +186,8 @@ def _handle_execution(
 
             # Step 6: Invoke modify_before_retry_loop
             for interceptor in interceptors:
-                context_with_transport_request._transport_request = interceptor.modify_before_retry_loop(
-                    context_with_transport_request
+                context_with_transport_request._transport_request = (
+                    interceptor.modify_before_retry_loop(context_with_transport_request)
                 )
 
             # Step 7: Acquire the retry token.
@@ -233,7 +237,9 @@ def _handle_execution(
         # The response will be set either with the modeled output or an exception. The
         # transport_request and transport_response may be set or None.
         execution_context = cast(
-            InterceptorContext[Input, Output, DafnyRequest | None, DafnyResponse | None],
+            InterceptorContext[
+                Input, Output, DafnyRequest | None, DafnyResponse | None
+            ],
             context,
         )
         return self._finalize_execution(interceptors, execution_context)
@@ -255,10 +261,14 @@ def _handle_attempt(
             if config.dafnyImplInterface.impl is None:
                 raise Exception("No impl found on the operation config.")
 
-            context_with_response = cast(InterceptorContext[Input, None, DafnyRequest, DafnyResponse], context)
+            context_with_response = cast(
+                InterceptorContext[Input, None, DafnyRequest, DafnyResponse], context
+            )
 
-            context_with_response._transport_response = config.dafnyImplInterface.handle_request(
-                input=context_with_response.transport_request
+            context_with_response._transport_response = (
+                config.dafnyImplInterface.handle_request(
+                    input=context_with_response.transport_request
+                )
             )
 
             # Step 7n: Invoke read_after_transmit
@@ -267,8 +277,8 @@ def _handle_attempt(
 
             # Step 7o: Invoke modify_before_deserialization
             for interceptor in interceptors:
-                context_with_response._transport_response = interceptor.modify_before_deserialization(
-                    context_with_response
+                context_with_response._transport_response = (
+                    interceptor.modify_before_deserialization(context_with_response)
                 )
 
             # Step 7p: Invoke read_before_deserialization
@@ -280,7 +290,9 @@ def _handle_attempt(
                 InterceptorContext[Input, Output, DafnyRequest, DafnyResponse],
                 context_with_response,
             )
-            context_with_output._response = deserialize(context_with_output._transport_response, config)
+            context_with_output._response = deserialize(
+                context_with_output._transport_response, config
+            )
 
             # Step 7r: Invoke read_after_deserialization
             for interceptor in interceptors:
@@ -306,7 +318,9 @@ def _finalize_attempt(
         # Step 7s: Invoke modify_before_attempt_completion
         try:
             for interceptor in interceptors:
-                context._response = interceptor.modify_before_attempt_completion(context)
+                context._response = interceptor.modify_before_attempt_completion(
+                    context
+                )
         except Exception as e:
             context._response = e
 
@@ -322,7 +336,9 @@ def _finalize_attempt(
     def _finalize_execution(
         self,
         interceptors: list[Interceptor[Input, Output, DafnyRequest, DafnyResponse]],
-        context: InterceptorContext[Input, Output, DafnyRequest | None, DafnyResponse | None],
+        context: InterceptorContext[
+            Input, Output, DafnyRequest | None, DafnyResponse | None
+        ],
     ) -> Output:
         try:
             # Step 9: Invoke modify_before_completion

DynamoDbEncryption/runtimes/python/src/aws_dbesdk_dynamodb/smithygenerated/aws_cryptography_dbencryptionsdk_dynamodb/dafny_to_aws_sdk.py

@@ -21,30 +21,40 @@ def com_amazonaws_dynamodb_AttributeValue(dafny_input):
     # Convert AttributeValue
     if isinstance(dafny_input, AttributeValue_S):
         AttributeValue_union_value = {
-            "S": b"".join(ord(c).to_bytes(2, "big") for c in dafny_input.S).decode("utf-16-be")
+            "S": b"".join(ord(c).to_bytes(2, "big") for c in dafny_input.S).decode(
+                "utf-16-be"
+            )
         }
     elif isinstance(dafny_input, AttributeValue_N):
         AttributeValue_union_value = {
-            "N": b"".join(ord(c).to_bytes(2, "big") for c in dafny_input.N).decode("utf-16-be")
+            "N": b"".join(ord(c).to_bytes(2, "big") for c in dafny_input.N).decode(
+                "utf-16-be"
+            )
         }
     elif isinstance(dafny_input, AttributeValue_B):
         AttributeValue_union_value = {"B": bytes(dafny_input.B)}
     elif isinstance(dafny_input, AttributeValue_SS):
         AttributeValue_union_value = {
             "SS": [
-                b"".join(ord(c).to_bytes(2, "big") for c in list_element).decode("utf-16-be")
+                b"".join(ord(c).to_bytes(2, "big") for c in list_element).decode(
+                    "utf-16-be"
+                )
                 for list_element in dafny_input.SS
             ]
         }
     elif isinstance(dafny_input, AttributeValue_NS):
         AttributeValue_union_value = {
             "NS": [
-                b"".join(ord(c).to_bytes(2, "big") for c in list_element).decode("utf-16-be")
+                b"".join(ord(c).to_bytes(2, "big") for c in list_element).decode(
+                    "utf-16-be"
+                )
                 for list_element in dafny_input.NS
             ]
         }
     elif isinstance(dafny_input, AttributeValue_BS):
-        AttributeValue_union_value = {"BS": [bytes(list_element) for list_element in dafny_input.BS]}
+        AttributeValue_union_value = {
+            "BS": [bytes(list_element) for list_element in dafny_input.BS]
+        }
     elif isinstance(dafny_input, AttributeValue_M):
         AttributeValue_union_value = {
             "M": {