INNER CODE UNIT · Rust

spawn_jobs

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

async fn spawn_jobs(
    target_db: TargetDB,
    args: Arc<cli::DaemonArgs>,
    embedding_tx: Sender<EmbeddingProcessorArgs>,
    autotune_tx: Sender<AutotuneProcessorArgs>,
    cancel_token: CancellationToken,
) {
    let target_db = Arc::new(target_db);

    if args.embeddings {
        tokio::spawn(spawn_job(
            target_db.clone(),
            args.clone(),
            JobType::Embeddings(embedding_tx),
            cancel_token.clone(),
        ));
    }

View source record →