Flush at every migrated file

This commit is contained in:
Aode (lion) 2021-11-01 10:38:11 -05:00
parent ccb9f49b8b
commit 93c268fc58

View file

@ -137,6 +137,17 @@ impl UploadManager {
self.inner self.inner
.settings_tree .settings_tree
.insert(STORE_MIGRATION_PROGRESS, key)?; .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(()) Ok(())