Function drain_queue 

pub async fn drain_queue<'e, E>(
    executor: E,
    queue: &str,
) -> Result<u64, AwaError>
where
    E: PgExecutor<'e>,

Drain a queue: cancel all non-running, non-terminal jobs.