Agent
Attributes
attribute
id= uuid4()
attribute
specs_dir= specs_dir
attribute
name= name
attribute
llm= llm
attribute
start_node= start_node
attribute
registry= registry or Registry()
attribute
state_storage= state_storage or InMemoryStateStorage()
attribute
iteration_count= 0
attribute
max_iterations= max_iterations
attribute
logger= logging.LoggerAdapter(logger, {'agent_id': str(self.id), 'agent_name': self.name})
Functions
func
__init____init__(self, /, specs_dir, start_node, *, name='Agent', llm, registry=None, state_storage=None, max_iterations=50)
param
selfparam
specs_dirstr
param
start_nodestr
param
namestr
= 'Agent'
param
llmBaseChatModel
param
registryRegistry | None
= None
param
state_storageStateStorage | None
= None
param
max_iterationsint
= 50
Returns
None
func
stepstep(self, /, input_, context=None) -> ExecutorOutput
param
selfparam
input_str | ExecutorInput
param
contextdict[str, Any] | None
= None
Returns
ExecutorOutput
func
_process_input_loop_process_input_loop(self) -> None
param
selfReturns
None
func
_on_exit_input_loop_on_exit_input_loop(self, /, task) -> None
param
selfparam
taskTask[None]
Returns
None
func
_get_node_actor_cfg_get_node_actor_cfg(self, /, output) -> NodeAgentConfig
param
selfparam
outputExecutorOutput
Returns
NodeAgentConfig
func
_create_initial_node_actor_create_initial_node_actor(self, /, input_, execution_id) -> NodeActor[Any]
param
selfparam
input_ExecutorInput
param
execution_idUUID
Returns
NodeActor[Any]
func
_create_executor_create_executor(self, /, input_) -> Executor
param
selfparam
input_str | ExecutorInput
Returns
Executor
func
_create_executor_input_create_executor_input(self, /, input_, context=None) -> ExecutorInput
param
selfparam
input_str
param
contextdict[str, Any] | None
= None
Returns
ExecutorInput
Last updated on