Module queries

Module queries 

Source
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