File tree Expand file tree Collapse file tree 1 file changed +4
-2
lines changed
src/dynamo/request/batchwritesingletable Expand file tree Collapse file tree 1 file changed +4
-2
lines changed Original file line number Diff line number Diff line change @@ -59,13 +59,15 @@ export class BatchWriteSingleTableRequest<T> {
5959
6060 return this . dynamoRx . batchWriteItem ( batchWriteItemInput ) . pipe (
6161 tap ( ( batchWriteManyResponse : BatchWriteItemOutput ) => {
62- if ( batchWriteManyResponse . UnprocessedItems ) {
62+ if ( batchWriteManyResponse . UnprocessedItems && batchWriteManyResponse . UnprocessedItems [ this . tableName ] ) {
6363 this . itemsToProcess . unshift ( ...batchWriteManyResponse . UnprocessedItems [ this . tableName ] )
6464 }
6565 } ) ,
6666 map ( ( batchWriteManyResponse : BatchWriteItemOutput ) => ( {
6767 remainingItems : this . itemsToProcess . length ,
68- capacityExceeded : ! ! batchWriteManyResponse . UnprocessedItems ,
68+ capacityExceeded : ! ! (
69+ batchWriteManyResponse . UnprocessedItems && batchWriteManyResponse . UnprocessedItems [ this . tableName ]
70+ ) ,
6971 consumedCapacity : batchWriteManyResponse . ConsumedCapacity ,
7072 } ) )
7173 )
You can’t perform that action at this time.
0 commit comments