Skip to content

Commit 5e566ca

Browse files
committed
Fix logic of handling UnprocessedItems in writeBatch
1 parent 180a113 commit 5e566ca

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

table.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -40,7 +40,7 @@ func (sync *syncState) writeBatch(
4040

4141
consumedCapacity = append(consumedCapacity, output.ConsumedCapacity...)
4242

43-
if output.UnprocessedItems != nil {
43+
if len(output.UnprocessedItems) != 0 {
4444
logger.WithFields(logging.Fields{
4545
"Unprocessed Items Size": len(output.UnprocessedItems),
4646
"Source Table": key.sourceTable,

0 commit comments

Comments
 (0)