Skip to main content

clean_queue

Function clean_queue 

Source
pub async fn clean_queue(pool: &PgPool, queue: &str)
Expand description

Delete all jobs, queue metadata, and admin caches for a specific queue.

Explicitly deletes the queue_state_counts row to prevent accumulated cache drift from affecting assertions. The DELETE trigger normally handles this, but concurrent test runs against a shared DB can cause small delta errors that compound over time.