INNER CODE UNIT · Rust

spawn_job

lanterndata/lantern · lantern_cli/src/daemon/mod.rs:89

async fn spawn_job(
    target_db: Arc<TargetDB>,
    args: Arc<cli::DaemonArgs>,
    job_type: JobType,
    parent_cancel_token: CancellationToken,
) -> AnyhowVoidResult {
    let mut retry_interval = 5;

    let log_label = match job_type {
        JobType::Embeddings(_) => "embeddings",
        JobType::Autotune(_) => "autotune",
    };

    let logger = Arc::new(Logger::new(
        &format!("{} - {log_label}", &target_db.name),
        args.log_level.value(),
    ));

View source record →