Client Usage
Retry Failed Tasks
It is possible to retry one or more tasks from running workflows. Those tasks can be targeted by id, by status or by class.
// stub targeting a running HelloWorkflow workflow with a specific id
HelloWorkflow w =
client.getWorkflowById(HelloWorkflow.class, "05694902-5aa4-469f-824c-7015b0df906c);
// retry a specific task from this instance
client.retryTasks(w, "f2ebeb38-5329-4348-90d4-615b4a5c2214");
// retry all failed tasks
client.retryTasks(w, DeferredStatus.FAILED);
// retry all failed HelloService tasks
client.retryTasks(w, DeferredStatus.FAILED, HelloService.class);
// stub targeting a running HelloWorkflow workflow with a specific id
val w : HelloWorkflow =
client.getWorkflowById(HelloWorkflow::class.java, "05694902-5aa4-469f-824c-7015b0df906c")
// retry a specific task from this instance
client.retryTasks(w, "f2ebeb38-5329-4348-90d4-615b4a5c2214")
// retry all failed tasks of this instance
client.retryTasks(w, DeferredStatus.FAILED)
// retry all failed HelloService tasks of this instance
client.retryTasks(w, DeferredStatus.FAILED, HelloService::class.java)
We can also retry tasks on running workflows targeted by tag.
The retryTasks method returns when the adhoc message is sent to Pulsar. We can use the retryTasksAsync method if we want to send the adhoc message asynchronously.
Tasks are considered failed when all automatic retries have failed.