interceptBeforeNode

fun <TFeature : Any> interceptBeforeNode(interceptContext: InterceptContext<TFeature>, handle: suspend TFeature.(eventContext: NodeBeforeExecuteContext) -> Unit)(source)

Intercepts node execution before it starts.

Parameters

handle

The handler that processes before-node events

Example:

pipeline.interceptBeforeNode(InterceptContext) { eventContext ->
logger.info("Node ${eventContext.node.name} is about to execute with input: ${eventContext.input}")
}