Package step.core.plugins

Interface ExecutionCallbacks

All Known Subinterfaces:

ExecutionEnginePlugin

All Known Implementing Classes:

AbstractExecutionEnginePlugin, BaseArtefactPlugin, BasePlugin, CompositeFunctionTypePlugin, FunctionPlugin, GeneralScriptFunctionPlugin, LocalCompositeFunctionPlugin, LocalFunctionPlugin, LocalRepositoryPlugin, MeasurementPlugin, ParameterManagerPlugin, QuotaManagerPlugin, ThreadManagerPlugin, ThreadPoolPlugin, TimeSeriesExecutionPlugin, ViewPlugin

public interface ExecutionCallbacks

Method Summary

Modifier and Type	Method	Description
void	afterExecutionEnd(ExecutionContext context)
void	afterFunctionExecution(ExecutionContext context, ReportNode node, Function function, step.functions.io.Output<jakarta.json.JsonObject> output)	This hook is called immediately after a Function is executed in CallFunctionHandler.
void	afterReportNodeExecution(ExecutionContext context, ReportNode node)
void	afterReportNodeSkeletonCreation(ExecutionContext context, ReportNode node)
void	associateThread(ExecutionContext context, Thread thread)
void	associateThread(ExecutionContext context, Thread thread, long parentThreadId)
void	beforeExecutionEnd(ExecutionContext context)
void	beforeFunctionExecution(ExecutionContext context, ReportNode node, Function function)	This hook is called before a Function is executed in CallFunctionHandler just after the Function has been resolved The hook is also called in simulation mode
void	beforePlanImport(ExecutionContext context)
void	beforeReportNodeExecution(ExecutionContext context, ReportNode node)
void	executionStart(ExecutionContext context)
void	onErrorContributionRemoval(ExecutionContext context, ReportNode node)
void	onReportNodeRemoval(ExecutionContext context, ReportNode node)
void	unassociateThread(ExecutionContext context, Thread thread)

Method Details

beforeFunctionExecution

void beforeFunctionExecution(ExecutionContext context,
 ReportNode node,
 Function function)

This hook is called before a Function is executed in CallFunctionHandler just after the Function has been resolved The hook is also called in simulation mode

Parameters:

context - the ExecutionContext

function - the resolved Function that will be executed

afterFunctionExecution

void afterFunctionExecution(ExecutionContext context,
 ReportNode node,
 Function function,
 step.functions.io.Output<jakarta.json.JsonObject> output)

This hook is called immediately after a Function is executed in CallFunctionHandler. The ReportNode provided as argument is therefore not reflecting the final status. If you need the final status after CallFunction execution use the hook afterReportNodeExecution(ExecutionContext, ReportNode) instead. The hook is also called in simulation mode.

Parameters:

context - the ExecutionContext

node -

function - the Function that has been executed

output - the result Output of the execution

afterReportNodeSkeletonCreation

void afterReportNodeSkeletonCreation(ExecutionContext context,
 ReportNode node)

beforeReportNodeExecution

void beforeReportNodeExecution(ExecutionContext context,
 ReportNode node)

afterReportNodeExecution

void afterReportNodeExecution(ExecutionContext context,
 ReportNode node)

onReportNodeRemoval

void onReportNodeRemoval(ExecutionContext context,
 ReportNode node)

onErrorContributionRemoval

void onErrorContributionRemoval(ExecutionContext context,
 ReportNode node)

associateThread

void associateThread(ExecutionContext context,
 Thread thread)

associateThread

void associateThread(ExecutionContext context,
 Thread thread,
 long parentThreadId)

unassociateThread

void unassociateThread(ExecutionContext context,
 Thread thread)

beforePlanImport

void beforePlanImport(ExecutionContext context)

executionStart

void executionStart(ExecutionContext context)

beforeExecutionEnd

void beforeExecutionEnd(ExecutionContext context)

afterExecutionEnd

void afterExecutionEnd(ExecutionContext context)