From 93c268fc58e206808da096d657977f41d6c0f64e Mon Sep 17 00:00:00 2001 From: "Aode (lion)" Date: Mon, 1 Nov 2021 10:38:11 -0500 Subject: [PATCH] Flush at every migrated file --- src/upload_manager.rs | 11 +++++++++++ 1 file changed, 11 insertions(+) diff --git a/src/upload_manager.rs b/src/upload_manager.rs index 7bea06c..a66f9b0 100644 --- a/src/upload_manager.rs +++ b/src/upload_manager.rs @@ -137,6 +137,17 @@ impl UploadManager { self.inner .settings_tree .insert(STORE_MIGRATION_PROGRESS, key)?; + + let (ident, detail, settings) = futures_util::future::join3( + self.inner.identifier_tree.flush_async(), + self.inner.details_tree.flush_async(), + self.inner.settings_tree.flush_async(), + ) + .await; + + ident?; + detail?; + settings?; } Ok(())