Skip to main content

apalis_sqlite/queries/
mod.rs

1//! Queries needed for polling, updating and exposing tasks.
2// /// ACK a task on success or failure
3mod ack_task;
4
5/// Fetch tasks by their IDs
6mod fetch_by_id;
7
8/// Fetch the next stream of tasks
9mod fetch_next;
10/// Keep workers alive by updating their heartbeat
11mod keep_alive;
12/// List available queues
13mod list_queues;
14/// List tasks in a specific queue
15mod list_tasks;
16/// List workers
17mod list_workers;
18/// Lock a task for processing
19mod lock_task;
20/// Metrics related queries
21mod metrics;
22/// Re-enqueue orphaned tasks that were being processed by dead workers
23mod reenqueue_orphaned;
24/// Register a new worker in the database
25mod register_worker;
26/// Vacuum the database to optimize space
27mod vacuum;
28/// Wait for tasks to complete and stream their results
29mod wait_for;
30
31pub use crate::queries::{
32    ack_task::AckPayload, ack_task::ack_tasks, fetch_next::fetch_next, keep_alive::keep_alive,
33    lock_task::lock_tasks, reenqueue_orphaned::reenqueue_abandoned,
34    reenqueue_orphaned::reenqueue_orphaned, register_worker::register_worker,
35};
36pub use crate::sink::push_tasks;