agents-core/ai.koog.agents.core.feature.pipeline/AIAgentGraphPipeline/interceptNodeExecutionCompleted

interceptNodeExecutionCompleted

fun interceptNodeExecutionCompleted(feature: AIAgentGraphFeature<*, *>, handle: suspend (eventContext: NodeExecutionCompletedContext) -> Unit)(source)

Intercepts node execution after it completes.

Parameters

feature

The feature associated with this handler.

handle

The handler that processes after-node events

Example:

pipeline.interceptNodeExecutionCompleted(feature) { eventContext ->
    logger.info("Node ${eventContext.node.name} executed with input: ${eventContext.input} and produced output: ${eventContext.output}")
}