Skip to main content

fetch_next

Function fetch_next 

Source
pub async fn fetch_next<'a, E>(
    executor: E,
    config: &Config,
    worker: &WorkerContext,
) -> Result<Vec<Task<Vec<u8>>>, Error>
where E: Executor<'a, Database = Sqlite>,
Expand description

Fetch the next batch of tasks from the sqlite backend