fix: only commit when there is something to commit

getdozer · Oct 4, 2023 · 2a8004a · 2a8004a
1 parent 9269db4
commit 2a8004a
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/dozer-core/src/forwarder.rs b/dozer-core/src/forwarder.rs
@@ -182,7 +182,8 @@ impl SourceChannelManager {
 
     fn should_participate_in_commit(&self) -> bool {
         self.num_uncommitted_ops >= self.commit_sz
-            || self
+            || self.num_uncommitted_ops > 0
+                && self
                 .last_commit_instant
                 .elapsed()
                 .unwrap_or(self.max_duration_between_commits) // In case of system time drift, we just commit