From 3305fb76d5cb2862c9b0f8bb5396c496b16dde08 Mon Sep 17 00:00:00 2001 From: Darin Kelkhoff Date: Wed, 16 Nov 2022 14:42:19 -0600 Subject: [PATCH] Fixed to insert & update correct lists --- .../etl/streamedwithfrontend/LoadViaInsertOrUpdateStep.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/qqq-backend-core/src/main/java/com/kingsrook/qqq/backend/core/processes/implementations/etl/streamedwithfrontend/LoadViaInsertOrUpdateStep.java b/qqq-backend-core/src/main/java/com/kingsrook/qqq/backend/core/processes/implementations/etl/streamedwithfrontend/LoadViaInsertOrUpdateStep.java index 3254e71e..eb6dff48 100644 --- a/qqq-backend-core/src/main/java/com/kingsrook/qqq/backend/core/processes/implementations/etl/streamedwithfrontend/LoadViaInsertOrUpdateStep.java +++ b/qqq-backend-core/src/main/java/com/kingsrook/qqq/backend/core/processes/implementations/etl/streamedwithfrontend/LoadViaInsertOrUpdateStep.java @@ -80,7 +80,7 @@ public class LoadViaInsertOrUpdateStep extends AbstractLoadStep InsertInput insertInput = new InsertInput(runBackendStepInput.getInstance()); insertInput.setSession(runBackendStepInput.getSession()); insertInput.setTableName(tableMetaData.getName()); - insertInput.setRecords(runBackendStepInput.getRecords()); + insertInput.setRecords(recordsToInsert); getTransaction().ifPresent(insertInput::setTransaction); insertInput.setAsyncJobCallback(runBackendStepInput.getAsyncJobCallback()); InsertOutput insertOutput = new InsertAction().execute(insertInput); @@ -92,7 +92,7 @@ public class LoadViaInsertOrUpdateStep extends AbstractLoadStep UpdateInput updateInput = new UpdateInput(runBackendStepInput.getInstance()); updateInput.setSession(runBackendStepInput.getSession()); updateInput.setTableName(tableMetaData.getName()); - updateInput.setRecords(runBackendStepInput.getRecords()); + updateInput.setRecords(recordsToUpdate); getTransaction().ifPresent(updateInput::setTransaction); updateInput.setAsyncJobCallback(runBackendStepInput.getAsyncJobCallback()); UpdateOutput updateOutput = new UpdateAction().execute(updateInput);