diff --git a/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/DataLoaderService.java b/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/DataLoaderService.java
index eb09e943cc..3c82b6d0dc 100644
--- a/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/DataLoaderService.java
+++ b/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/DataLoaderService.java
@@ -1015,6 +1015,10 @@ protected IDataWriter chooseDataWriter(Batch batch) {
                                 }
                             };
                             processor.process(ctx);
+                            
+                            if (loadInfo.getCurrentBatchCount() == 0) {
+                                loadInfo.setStatus(ProcessStatus.OK);
+                            }
                         } catch (Exception e) {
                             isError = true;
                             throw e;
@@ -1120,7 +1124,6 @@ public boolean beforeBatchStarted(DataContext context) {
                     return true;
                 }
             }
-            processInfo.setStatus(ProcessStatus.OK);
             return false;
         }