pub async fn retry_task( broker_url: &str, queue: &str, task_id_str: &str, ) -> Result<()>
Retry a failed task (from any queue)