fix: workaround to fix future is not Sync

Author: v0y4g3r

src/script/src/python/builtins.rs

@@ -962,7 +962,7 @@ pub(crate) mod greptime_builtin {
                         Ok(obj) => match py_vec_obj_to_array(&obj, vm, 1){
                             Ok(v) => if v.len()==1{
                                 Ok(v)
-                            }else{
+                            } else {
                                 Err(vm.new_runtime_error(format!("Expect return's length to be at most one, found to be length of {}.", v.len())))
                             },
                             Err(err) => Err(vm

src/storage/src/compaction/scheduler.rs

@@ -207,7 +207,7 @@ impl<R: CompactionRequest, T: CompactionTask, P: Picker<R, T>> CompactionHandler
                             debug!("Executing compaction request: {}", region_id);
                             if let Err(e) = self.handle_compaction_request(req, token).await {
                                 error!(e; "Failed to submit compaction task for region: {}", region_id);
-                            }else{
+                            } else {
                                 info!("Submitted region compaction task: {}", region_id);
                             }
                         } else {

src/storage/src/flush.rs

@@ -215,7 +215,7 @@ impl<S: LogStore> FlushJob<S> {
         Ok(metas)
     }
 
-    async fn write_manifest_and_apply(&self, file_metas: &[FileMeta]) -> Result<()> {
+    async fn write_manifest_and_apply(&mut self, file_metas: &[FileMeta]) -> Result<()> {
         let edit = RegionEdit {
             region_version: self.shared.version_control.metadata().version(),
             flushed_sequence: Some(self.flush_sequence),
@@ -246,7 +246,7 @@ 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.write_manifest_and_apply(&file_metas).await?;
 
         if let Some(cb) = self.on_success.lock().await.take() {
             cb.await;