fn spawn()

in src/columnar_storage/src/compaction/executor.rs [262:272]

• 11 lines of code
• 2 McCabe index (conditional complexity)

    fn spawn(self) {
        let rt = self.executor.inner.runtime.clone();
        rt.spawn(async move {
            if let Err(e) = self.executor.do_compaction(&self.task).await {
                error!("Do compaction failed, err:{e:?}");
                self.executor.on_failure(&self.task);
            } else {
                self.executor.on_success(&self.task);
            }
        });
    }