fix: workaround to bypass future not Sync error

Author: v0y4g3r

src/storage/src/flush.rs

@@ -215,7 +215,18 @@ impl<S: LogStore> FlushJob<S> {
         Ok(metas)
     }
 
-    async fn write_manifest_and_apply(&self, file_metas: &[FileMeta]) -> Result<()> {
+    /// Generates random SST file name in format: `^[a-f\d]{8}(-[a-f\d]{4}){3}-[a-f\d]{12}.parquet$`
+    fn generate_sst_file_name() -> String {
+        format!("{}.parquet", Uuid::new_v4().hyphenated())
+    }
+}
+
+#[async_trait]
+impl<S: LogStore> Job for FlushJob<S> {
+    // TODO(yingwen): [flush] Support in-job parallelism (Flush memtables concurrently)
+    async fn run(&mut self, ctx: &Context) -> Result<()> {
+        let file_metas = self.write_memtables_to_layer(ctx).await?;
+
         let edit = RegionEdit {
             region_version: self.shared.version_control.metadata().version(),
             flushed_sequence: Some(self.flush_sequence),
@@ -232,21 +243,7 @@ impl<S: LogStore> FlushJob<S> {
                 Some(self.max_memtable_id),
             )
             .await?;
-        self.wal.obsolete(self.flush_sequence).await
-    }
-
-    /// Generates random SST file name in format: `^[a-f\d]{8}(-[a-f\d]{4}){3}-[a-f\d]{12}.parquet$`
-    fn generate_sst_file_name() -> String {
-        format!("{}.parquet", Uuid::new_v4().hyphenated())
-    }
-}
-
-#[async_trait]
-impl<S: LogStore> Job for FlushJob<S> {
-    // TODO(yingwen): [flush] Support in-job parallelism (Flush memtables concurrently)
-    async fn run(&mut self, ctx: &Context) -> Result<()> {
-        let file_metas = self.write_memtables_to_layer(ctx).await?;
-        Self::write_manifest_and_apply(self, &file_metas).await?;
+        self.wal.obsolete(self.flush_sequence).await?;
 
         if let Some(cb) = self.on_success.lock().await.take() {
             cb.await;