diff --git a/qqq-backend-core/src/main/java/com/kingsrook/qqq/backend/core/processes/implementations/tablesync/AbstractTableSyncTransformStep.java b/qqq-backend-core/src/main/java/com/kingsrook/qqq/backend/core/processes/implementations/tablesync/AbstractTableSyncTransformStep.java
index 71769499..66372f1a 100644
--- a/qqq-backend-core/src/main/java/com/kingsrook/qqq/backend/core/processes/implementations/tablesync/AbstractTableSyncTransformStep.java
+++ b/qqq-backend-core/src/main/java/com/kingsrook/qqq/backend/core/processes/implementations/tablesync/AbstractTableSyncTransformStep.java
@@ -37,6 +37,7 @@ import com.kingsrook.qqq.backend.core.actions.tables.QueryAction;
 import com.kingsrook.qqq.backend.core.actions.values.QPossibleValueTranslator;
 import com.kingsrook.qqq.backend.core.exceptions.QException;
 import com.kingsrook.qqq.backend.core.logging.QLogger;
+import com.kingsrook.qqq.backend.core.model.actions.audits.AuditSingleInput;
 import com.kingsrook.qqq.backend.core.model.actions.processes.ProcessSummaryLine;
 import com.kingsrook.qqq.backend.core.model.actions.processes.ProcessSummaryLineInterface;
 import com.kingsrook.qqq.backend.core.model.actions.processes.RunBackendStepInput;
@@ -92,8 +93,9 @@ public abstract class AbstractTableSyncTransformStep extends AbstractTransformSt
       .withSingularPastMessage("was not synced, because it is ")
       .withPluralPastMessage("were not synced, because they are ");
 
-   protected RunBackendStepInput runBackendStepInput = null;
-   protected RecordLookupHelper  recordLookupHelper  = null;
+   protected RunBackendStepInput  runBackendStepInput  = null;
+   protected RunBackendStepOutput runBackendStepOutput = null;
+   protected RecordLookupHelper   recordLookupHelper   = null;
 
    private QPossibleValueTranslator possibleValueTranslator;
 
@@ -193,6 +195,7 @@ public abstract class AbstractTableSyncTransformStep extends AbstractTransformSt
       }
 
       this.runBackendStepInput = runBackendStepInput;
+      this.runBackendStepOutput = runBackendStepOutput;
 
       SyncProcessConfig config = getSyncProcessConfig();
 
@@ -426,4 +429,17 @@ public abstract class AbstractTableSyncTransformStep extends AbstractTransformSt
       }
    }
 
+
+
+   /*******************************************************************************
+    ** Let the subclass "easily" add an audit to be inserted on the Execute step.
+    *******************************************************************************/
+   protected void addAuditForExecuteStep(AuditSingleInput auditSingleInput)
+   {
+      if(StreamedETLWithFrontendProcess.STEP_NAME_EXECUTE.equals(this.runBackendStepInput.getStepName()))
+      {
+         this.runBackendStepOutput.addAuditSingleInput(auditSingleInput);
+      }
+   }
+
 }