interceptNodeExecutionCompleted
fun <TFeature : Any> interceptNodeExecutionCompleted(interceptContext: InterceptContext<TFeature>, handle: suspend TFeature.(eventContext: NodeExecutionCompletedContext) -> Unit)(source)
Intercepts node execution after it completes.
Parameters
handle
The handler that processes after-node events
Example:
pipeline.interceptNodeExecutionCompleted(interceptContext) { eventContext ->
logger.info("Node ${eventContext.node.name} executed with input: ${eventContext.input} and produced output: ${eventContext.output}")
}
Content copied to clipboard