fn delete_ssts()

in src/columnar_storage/src/compaction/executor.rs [224:253]

• 30 lines of code
• 5 McCabe index (conditional complexity)

    fn delete_ssts<I>(&self, ids: I)
    where
        I: Iterator<Item = FileId>,
    {
        let (_, results) = TokioScope::scope_and_block(|scope| {
            for id in ids {
                let path = Path::from(self.inner.sst_path_gen.generate(id));
                trace!(id, "Delete sst file");
                scope.spawn(async move {
                    self.inner
                        .store
                        .delete(&path)
                        .await
                        .with_context(|| format!("failed to delete file, path:{path}"))
                });
            }
        });
        for res in results {
            match res {
                Err(e) => {
                    error!("Failed to join delete task, err:{e}")
                }
                Ok(v) => {
                    if let Err(e) = v {
                        error!("Failed to delete sst, err:{e}")
                    }
                }
            }
        }
    }