diff --git a/lib/lib-dynamodb/src/test/lib-dynamodb.e2e.spec.ts b/lib/lib-dynamodb/src/test/lib-dynamodb.e2e.spec.ts index 674904a7ac51..3035888d3a64 100644 --- a/lib/lib-dynamodb/src/test/lib-dynamodb.e2e.spec.ts +++ b/lib/lib-dynamodb/src/test/lib-dynamodb.e2e.spec.ts @@ -346,6 +346,19 @@ describe( }) .catch(passError); + for (const k of Object.keys(data)) { + // this GET request uses ConsistentRead to ensure the previous TransactWrite + // has completed before the next TransactRead fires. + await doc + .get({ + TableName, + Key: { + id: k + "-transact", + }, + }) + .catch(passError); + } + log.transactRead = await doc .transactGet({ TransactItems: [