Skip to content

Commit 37a24b4

Browse files
author
Lucas McDonald
committed
m
1 parent d4dcd48 commit 37a24b4

File tree

1 file changed

+12
-10
lines changed

1 file changed

+12
-10
lines changed

TestVectors/runtimes/python/src/aws_dbesdk_dynamodb_test_vectors/internaldafny/extern/CreateInterceptedDDBTable.py

Lines changed: 12 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -132,16 +132,18 @@ def batch_write_item(self, **kwargs):
132132
# There isn't a resource shape for this;
133133
table_input = self._client_shape_to_resource_shape_converter.batch_write_item_request(kwargs)
134134
# table_output = self._table.batch_write_item(**table_input)
135-
batch_writer = self._table.batch_writer()
136-
for _, items in table_input["RequestItems"].items():
137-
for item in items:
138-
if "PutRequest" in item:
139-
batch_writer.put_item(item["PutRequest"]["Item"])
140-
elif "DeleteRequest" in item:
141-
batch_writer.delete_item(item["DeleteRequest"]["Key"])
142-
else:
143-
raise ValueError(f"Unknown request type: {item}")
144-
table_output = batch_writer.close()
135+
with self._table.batch_writer() as batch_writer:
136+
for _, items in table_input["RequestItems"].items():
137+
for item in items:
138+
if "PutRequest" in item:
139+
batch_writer.put_item(item["PutRequest"]["Item"])
140+
elif "DeleteRequest" in item:
141+
batch_writer.delete_item(item["DeleteRequest"]["Key"])
142+
else:
143+
raise ValueError(f"Unknown request type: {item}")
144+
# There isn't a shape for the output, but luckily the output can be an empty dict:
145+
# https://boto3.amazonaws.com/v1/documentation/api/latest/reference/services/dynamodb/client/batch_write_item.html
146+
table_output = {}
145147
client_output = self._resource_shape_to_client_shape_converter.batch_write_item_response(table_output)
146148
return client_output
147149

0 commit comments

Comments
 (0)