diff --git a/node/storage/src/log_store/flow_store.rs b/node/storage/src/log_store/flow_store.rs
index 8c2fae9..5ff4061 100644
--- a/node/storage/src/log_store/flow_store.rs
+++ b/node/storage/src/log_store/flow_store.rs
@@ -90,6 +90,14 @@ impl FlowStore {
}
self.db.delete_batch_list(batch_list)
}
+
+ pub fn get_raw_batch(&self, batch_index: u64) -> Result