AIAgentNonGraphPipeline
Represents a specific implementation of an AI agent pipeline that does not use graph-based processing. This class inherits from the base AIAgentPipeline class and may be used for handling workflows or data processing tasks that do not require graph-based data structures.
Parameters
The clock used for time-based operations within the pipeline
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.
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 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.