drain_worker

celers_cli::commands

Function drain_worker 

Source 
pub async fn drain_worker(broker_url: &str, worker_id: &str) -> Result<()>
Expand description

Drain worker (stop accepting new tasks)