Mark wal source transactional

Signed-off-by: Heinz N. Gies <[email protected]>
tremor-rs · Nov 1, 2021 · c832fce · c832fce
1 parent b70827b
commit c832fce
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/src/connectors/wal.rs b/src/connectors/wal.rs
@@ -107,6 +107,10 @@ impl Source for WalSource {
         dbg!(stream_id);
         self.wal.lock().await.ack(stream_id).await.unwrap()
     }
+
+    fn is_transactional(&self) -> bool {
+        true
+    }
 }
 
 struct WalSink {