diff --git a/dtc-aws-plugin/src/dynamo-db-plugin.ts b/dtc-aws-plugin/src/dynamo-db-plugin.ts index 8f0730a..09ffa6d 100644 --- a/dtc-aws-plugin/src/dynamo-db-plugin.ts +++ b/dtc-aws-plugin/src/dynamo-db-plugin.ts @@ -76,7 +76,7 @@ const cleanDynamoItems = async (clean: DynamoClean) => { if ('query' in clean) { const result = await documentClient.query({ - ConsistentRead: true, + ConsistentRead: clean.index ? false : true, TableName: clean.table, IndexName: clean.index, KeyConditionExpression: Object.entries(clean.query)