fn spawn()

in src/samplers/scheduler/mod.rs [91:105]

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

    fn spawn(common: Common) {
        if common.config().samplers().scheduler().enabled() {
            if let Ok(mut sampler) = Self::new(common.clone()) {
                common.runtime().spawn(async move {
                    loop {
                        let _ = sampler.sample().await;
                    }
                });
            } else if !common.config.fault_tolerant() {
                fatal!("failed to initialize scheduler sampler");
            } else {
                error!("failed to initialize scheduler sampler");
            }
        }
    }