Skip to main content

push_tasks

Function push_tasks 

Source
pub fn push_tasks<E>(
    conn: &mut E,
    queue: &str,
    buffer: Vec<PgTask>,
) -> impl Future<Output = Result<(), Error>> + Send
where for<'e> &'e mut E: Executor<'e, Database = Postgres> + Send,
Expand description

Push a batch of tasks to the database