AIAgentGraphPipeline
Represents a pipeline for AI agent graph execution, extending the functionality of AIAgentPipeline
. This class manages the execution of specific nodes in the pipeline using registered handlers.
Functions
Retrieves all features associated with the given agent context.
Intercepts LLM calls after they are made to process or log the response.
Intercepts and sets a handler to be invoked before an agent is closed.
Intercepts and sets a handler to be invoked before an agent is closed.
Intercepts the completion of an agent's operation and assigns a custom handler to process the result.
Intercepts and handles errors occurring during the execution of an AI agent's strategy.
Intercepts the completion of an agent's operation and assigns a custom handler to process the result.
Intercepts and handles errors occurring during the execution of an AI agent's strategy.
Intercepts on before an agent started to modify or enhance the agent.
Intercepts on before an agent started to modify or enhance the agent.
Intercepts LLM calls before they are made (deprecated name).
Sets a feature handler for agent context events.
Intercepts environment creation to allow features to modify or enhance the agent environment.
Intercepts LLM calls after they are made to process or log the response.
Intercepts LLM calls before they are made to modify or log the prompt.
Intercepts streaming operations after they complete to perform post-processing or cleanup.
Intercepts errors during the streaming process.
Intercepts stream frames as they are received during the streaming process.
Intercepts streaming operations before they begin to modify or log the streaming request.
Intercepts node execution after it completes.
Intercepts and handles node execution errors for a given feature.
Intercepts node execution before it starts.
Sets up an interceptor to handle the completion of a strategy for the given feature.
Sets up an interceptor to handle the completion of a strategy for the given feature.
Intercepts strategy started event to perform actions when an agent strategy begins execution.
Intercepts strategy started event to perform actions when an agent strategy begins execution.
Intercepts and handles tool calls for the specified feature and its implementation. Updates the tool call handler for the given feature key with a custom handler.
Intercepts the result of a tool call with a custom handler for a specific feature.
Sets up an interception mechanism to handle tool call failures for a specific feature.
Sets up an interception mechanism to handle tool call failures for a specific feature.
Intercepts the result of a tool call with a custom handler for a specific feature.
Intercepts and handles tool calls for the specified feature and its implementation. Updates the tool call handler for the given feature key with a custom handler.
Intercepts validation errors encountered during the execution of tools associated with the specified feature.
Intercepts validation errors encountered during the execution of tools associated with the specified feature.
Invoked before an agent is closed to perform necessary pre-closure operations.
Notifies all registered handlers that an agent has finished execution.
Transforms the agent environment by applying all registered environment transformers.
Notifies all registered handlers about an error that occurred during agent execution.
Notifies all registered handlers that an agent has started execution.
Notifies all registered LLM handlers after a language model call has completed.
Notifies all registered LLM handlers before a language model call is made.
Invoked after streaming from a language model completes.
Invoked if an error occurs during the streaming process.
Invoked when a stream frame is received during the streaming process.
Invoked before streaming from a language model begins.
Notifies all registered node handlers after a node has been executed.
Handles errors occurring during the execution of a node by invoking all registered node execution error handlers.
Notifies all registered node handlers before a node is executed.
Notifies all registered strategy handlers that a strategy has finished execution.
Notifies all registered strategy handlers that a strategy has started execution.
Notifies all registered tool handlers when a tool is called.