interceptNodeExecutionFailed
fun <TFeature : Any> interceptNodeExecutionFailed(interceptContext: InterceptContext<TFeature>, handle: suspend TFeature.(eventContext: NodeExecutionFailedContext) -> Unit)(source)
Intercepts and handles node execution errors for a given feature.
Parameters
interceptContext
The context containing the feature and its implementation required for interception.
handle
A suspend function that processes the node execution error within the scope of the provided feature.
Example:
pipeline.interceptNodeExecutionFailed(interceptContext) { eventContext ->
logger.error("Node ${eventContext.node.name} execution failed with error: ${eventContext.throwable}")
}
Content copied to clipboard