Skip to main content

apalis_postgres/queries/
mod.rs

1//! Queries needed for polling, updating and exposing tasks.
2mod fetch_by_id;
3mod fetch_next;
4mod handle_result;
5mod keep_alive;
6mod list_queues;
7mod list_tasks;
8mod list_workers;
9mod lock_task;
10mod metrics;
11mod reenqueue_orphaned;
12mod register_worker;
13mod wait_for;
14
15pub use crate::queries::{
16    fetch_next::fetch_next, handle_result::Payload as ResultPayload, handle_result::handle_results,
17    keep_alive::keep_alive, lock_task::lock_tasks, reenqueue_orphaned::reenqueue_abandoned,
18    reenqueue_orphaned::reenqueue_orphaned, register_worker::register_worker,
19};
20pub use crate::sink::push_tasks;