pub async fn queue_state_counts( pool: &PgPool, queue: &str, ) -> HashMap<String, i64>
Query job state counts for a queue, returning a map of state -> count.