Fix sink flush

getdozer · Mar 7, 2024 · 7da836d · 7da836d
1 parent 96a1cd8
commit 7da836d
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/dozer-core/src/executor/sink_node.rs b/dozer-core/src/executor/sink_node.rs
@@ -240,6 +240,7 @@ impl ReceiverLoop for SinkNode {
                 } else {
                     self.flush_scheduled_on_next_commit = true;
                 }
+                continue;
             }
             let op = receivers[index]
                 .recv()