brainslug.flow.execution.node

Class TaskNodeExecutor

java.lang.Object

brainslug.flow.execution.node.DefaultNodeExecutor<TaskNodeExecutor,AbstractTaskDefinition>

brainslug.flow.execution.node.TaskNodeExecutor

All Implemented Interfaces:

FlowNodeExecutor<AbstractTaskDefinition>

public class TaskNodeExecutor
extends DefaultNodeExecutor<TaskNodeExecutor,AbstractTaskDefinition>

Field Summary

Fields inherited from class brainslug.flow.execution.node.DefaultNodeExecutor

tokenOperations

Constructor Summary

Constructors

Constructor and Description
TaskNodeExecutor(DefinitionStore definitionStore, PredicateEvaluator predicateEvaluator, CallDefinitionExecutor callDefinitionExecutor, AsyncTriggerScheduler asyncTriggerScheduler)

Method Summary

Modifier and Type	Method and Description
FlowNodeExecutionResult	execute(AbstractTaskDefinition taskDefinition, ExecutionContext execution)
protected FlowNodeExecutionResult	executeWithOptionalAsyncRetry(AbstractTaskDefinition taskDefinition, ExecutionContext execution)
protected boolean	goalIsFulfilled(Identifier goalId, ExecutionContext execution)
protected boolean	isExecutable(AbstractTaskDefinition taskDefinition)
protected void	scheduleAsyncTask(AbstractTaskDefinition taskDefinition, ExecutionContext execution)

Methods inherited from class brainslug.flow.execution.node.DefaultNodeExecutor

removeIncomingTokens, takeAll, takeNone, withTokenOperations

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

TaskNodeExecutor

public TaskNodeExecutor(DefinitionStore definitionStore,
                        PredicateEvaluator predicateEvaluator,
                        CallDefinitionExecutor callDefinitionExecutor,
                        AsyncTriggerScheduler asyncTriggerScheduler)

Method Detail

execute

public FlowNodeExecutionResult execute(AbstractTaskDefinition taskDefinition,
                                       ExecutionContext execution)

Specified by:

execute in interface FlowNodeExecutor<AbstractTaskDefinition>

Overrides:

execute in class DefaultNodeExecutor<TaskNodeExecutor,AbstractTaskDefinition>

executeWithOptionalAsyncRetry

protected FlowNodeExecutionResult executeWithOptionalAsyncRetry(AbstractTaskDefinition taskDefinition,
                                                                ExecutionContext execution)

isExecutable

protected boolean isExecutable(AbstractTaskDefinition taskDefinition)

goalIsFulfilled

protected boolean goalIsFulfilled(Identifier goalId,
                                  ExecutionContext execution)

scheduleAsyncTask

protected void scheduleAsyncTask(AbstractTaskDefinition taskDefinition,
                                 ExecutionContext execution)