Expand description
Queries module for sqlite backend Module for various query implementations for the SQLite backend.
Each submodule contains specific query logic used by the backend.
Modulesยง
- fetch_
by_ id - Fetch tasks by their IDs
- keep_
alive - Keep workers alive by updating their heartbeat
- list_
queues - List available queues
- list_
tasks - List tasks in a specific queue
- list_
workers - List workers
- metrics
- Metrics related queries
- reenqueue_
orphaned - Re-enqueue orphaned tasks that were being processed by dead workers
- register_
worker - Register a new worker in the database
- vacuum
- Vacuum the database to optimize space
- wait_
for - Wait for tasks to complete and stream their results