pub async fn cancel_task( broker_url: &str, queue: &str, task_id_str: &str, ) -> Result<()>
Cancel a running or pending task