public class FailureUtils
extends java.lang.Object
Modifier and Type | Method and Description |
---|---|
static boolean |
isPermanentlyFailed(Protos.TaskInfo taskInfo)
Check if a Task has been marked as permanently failed.
|
static void |
setPermanentlyFailed(StateStore stateStore,
PodInstance podInstance)
Marks all tasks associated with this pod as failed.
|
public static boolean isPermanentlyFailed(Protos.TaskInfo taskInfo)
taskInfo
- The Task to check for failure.public static void setPermanentlyFailed(StateStore stateStore, PodInstance podInstance)
stateStore
- the state storage where any updated tasks will be storedpodInstance
- the pod whose tasks will be marked as failed