Add store cache flushing after each 100st entry

1 files changed, 8 insertions, 0 deletions

diff --git a/bin/core/imag-ids/src/main.rs b/bin/core/imag-ids/src/main.rs
index 308a56aa..c8da3cef 100644
--- a/bin/core/imag-ids/src/main.rs
+++ b/bin/core/imag-ids/src/main.rs
@@ -91,6 +91,14 @@ fn main() {
         .entries()
         .map_err_trace_exit_unwrap(1)
         .trace_unwrap_exit(1)
+        .enumerate()
+        .map(|(i, e)| {
+            if i % 100 == 0 {
+                let _ = rt.store().flush_cache();
+            }
+
+            e
+        })
         .filter(|id| collection_filter.filter(id))
         .filter(|id| match query_filter.as_ref() {
             None     => true,