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>,
Fetch the next batch of tasks from the sqlite backend