Class TaskStateManager

  • public final class TaskStateManager
    extends java.lang.Object
    Manages the states related to a task. The methods of this class are synchronized.
    • Method Detail

      • onTaskStateChanged

        public void onTaskStateChanged​(TaskState.State newState,
                                       java.util.Optional<java.lang.String> vertexPutOnHold,
                                       java.util.Optional<TaskState.RecoverableTaskFailureCause> cause)
        Updates the state of the task.
        newState - of the task.
        vertexPutOnHold - the vertex put on hold.
        cause - only provided as non-empty upon recoverable failures.
      • getCurrentTaskExecutionState

        public void getCurrentTaskExecutionState()