INNER CODE UNIT · Rust

producer_worker

lanterndata/lantern · lantern_cli/src/embeddings/mod.rs:132

async fn producer_worker(
    client: &mut Client,
    pk: &str,
    column: &str,
    full_table_name: &str,
    filter_sql: &str,
    limit_sql: &str,
    batch_size: usize,
    tx: Sender<Vec<Row>>,
) -> AnyhowVoidResult {
    let transaction = client.transaction().await?;
    // With portal we can execute a query and poll values from it in chunks
    let portal = transaction.bind(
            &format!(
                "SELECT {pk}::text, {column}::text FROM {full_table_name} {filter_sql} {limit_sql};",
                column = quote_ident(&column),
                pk = quote_ident(&pk)
            ),

View source record →