We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent ec44d0d commit 17140a5Copy full SHA for 17140a5
sdk/python/feast/infra/utils/aws_utils.py
@@ -1086,11 +1086,16 @@ class DynamoUnprocessedWriteItems(Exception):
1086
1087
1088
async def dynamo_write_items(dynamo_client, table_name: str, items: list[Any]) -> None:
1089
+ DYNAMO_MAX_WRITE_BATCH_SIZE = 25
1090
+
1091
async def _do_write(items):
1092
item_iter = iter(items)
1093
item_batches = []
1094
while True:
- item_batch = [item for item in itertools.islice(item_iter, 25)]
1095
+ item_batch = [
1096
+ item
1097
+ for item in itertools.islice(item_iter, DYNAMO_MAX_WRITE_BATCH_SIZE)
1098
+ ]
1099
if not item_batch:
1100
break
1101
0 commit comments