fix:do not skip adding of published record to `ddbEsItemsToBatchRead (#…

…4234)
webiny · Aug 21, 2024 · c5e2e7b · c5e2e7b
1 parent 7bb3196
commit c5e2e7b
Showing 1 changed file with 13 additions and 12 deletions.
diff --git a/packages/migrations/src/migrations/5.39.6/001/ddb-es/worker.ts b/packages/migrations/src/migrations/5.39.6/001/ddb-es/worker.ts
@@ -278,21 +278,22 @@ if (process.env.WEBINY_MIGRATION_5_39_6_001_BATCH_WRITE_MAX_CHUNK) {
                      */
 
                     const ddbEsLatestRecordKey = `${item.entryId}:L`;
-                    if (ddbEsItemsToBatchRead[ddbEsLatestRecordKey]) {
-                        continue;
+                    if (!ddbEsItemsToBatchRead[ddbEsLatestRecordKey]) {
+                        ddbEsItemsToBatchRead[ddbEsLatestRecordKey] = ddbEsEntryEntity.getBatch({
+                            PK: item.PK,
+                            SK: "L"
+                        });
                     }
 
-                    ddbEsItemsToBatchRead[ddbEsLatestRecordKey] = ddbEsEntryEntity.getBatch({
-                        PK: item.PK,
-                        SK: "L"
-                    });
-
                     const ddbEsPublishedRecordKey = `${item.entryId}:P`;
-                    if (item.status === "published" || !!item.locked) {
-                        ddbEsItemsToBatchRead[ddbEsPublishedRecordKey] = ddbEsEntryEntity.getBatch({
-                            PK: item.PK,
-                            SK: "P"
-                        });
+                    if (!ddbEsItemsToBatchRead[ddbEsPublishedRecordKey]) {
+                        if (item.status === "published" || !!item.locked) {
+                            ddbEsItemsToBatchRead[ddbEsPublishedRecordKey] =
+                                ddbEsEntryEntity.getBatch({
+                                    PK: item.PK,
+                                    SK: "P"
+                                });
+                        }
                     }
                 }