Interface TasksHandler.TasksListener
- All Known Implementing Classes:
TasksHandler.TasksListenerAdapter
- Enclosing class:
- TasksHandler
public static interface TasksHandler.TasksListener
TasksListener is a generic interface listening tasks
execution events. Methods in this interface will be called in a
tasks execution position where user most likely will want to get
notified.-
Method Summary
Modifier and TypeMethodDescriptionvoidonTaskFailed(Object id, Exception exception) Called when task execution result an error of any kind.voidCalled after tasks has been executed regardless if task execution succeeded or not.voidCalled before tasks is about to be executed.voidonTasksAutomaticFix(TasksHandler handler, StateContext<String, String> context) Called when tasks execution resulted an error and AUTOMATIC state is entered.voidCalled when some of a tasks in DAGs failed to execute and tasks execution in going to continue.voidCalled when after an execution of full DAGs if some of the tasks executed with an error.voidCalled when all DAGs have either never executed or previous execution was fully successful.voidCalled when all tasks has been executed successfully.voidonTaskSuccess(Object id) Called when task execution result without errors.
-
Method Details
-
onTasksStarted
void onTasksStarted()Called when all DAGs have either never executed or previous execution was fully successful. -
onTasksContinue
void onTasksContinue()Called when some of a tasks in DAGs failed to execute and tasks execution in going to continue. -
onTaskPreExecute
Called before tasks is about to be executed.- Parameters:
id- the task id
-
onTaskPostExecute
Called after tasks has been executed regardless if task execution succeeded or not.- Parameters:
id- the task id
-
onTaskFailed
Called when task execution result an error of any kind.- Parameters:
id- the task idexception- the exception
-
onTaskSuccess
Called when task execution result without errors.- Parameters:
id- the task id
-
onTasksSuccess
void onTasksSuccess()Called when all tasks has been executed successfully. -
onTasksError
void onTasksError()Called when after an execution of full DAGs if some of the tasks executed with an error. -
onTasksAutomaticFix
Called when tasks execution resulted an error and AUTOMATIC state is entered. This is a moment where extended state variables can be modified to allow continue into a READY state.- Parameters:
handler- the tasks handlercontext- the state context
-