Skip to main content

fetch_next

Function fetch_next 

Source
pub async fn fetch_next<E>(
    conn: &mut E,
    config: &Config,
    worker: &WorkerContext,
) -> Result<Vec<PgTask>, Error>
where for<'e> &'e mut E: Executor<'e, Database = Postgres>,
Expand description

Fetch the next batch of tasks from the sqlite backend