pub async fn drain_queue(pool: &PgPool, queue: &str) -> Result<u64, AwaError>
Drain a queue: cancel all non-running, non-terminal jobs.