(
self,
request: CreateAgent,
actor: Client,
# interface
interface: Union[AgentInterface, None] = None,
)
| 1083 | return await self._command(user_id=user_id, agent_id=agent_id, command=command) |
| 1084 | |
| 1085 | async def create_agent( |
| 1086 | self, |
| 1087 | request: CreateAgent, |
| 1088 | actor: Client, |
| 1089 | # interface |
| 1090 | interface: Union[AgentInterface, None] = None, |
| 1091 | ) -> AgentState: |
| 1092 | if request.llm_config is None: |
| 1093 | if request.model is None: |
| 1094 | raise ValueError("Must specify either model or llm_config in request") |
| 1095 | request.llm_config = await self.get_llm_config_from_handle( |
| 1096 | handle=request.model, context_window_limit=request.context_window_limit |
| 1097 | ) |
| 1098 | |
| 1099 | if request.embedding_config is None: |
| 1100 | if request.embedding is None: |
| 1101 | raise ValueError("Must specify either embedding or embedding_config in request") |
| 1102 | request.embedding_config = await self.get_embedding_config_from_handle( |
| 1103 | handle=request.embedding, |
| 1104 | embedding_chunk_size=request.embedding_chunk_size or constants.DEFAULT_EMBEDDING_CHUNK_SIZE, |
| 1105 | ) |
| 1106 | |
| 1107 | """Create a new agent using a config""" |
| 1108 | # Invoke manager |
| 1109 | return await self.agent_manager.create_agent( |
| 1110 | agent_create=request, |
| 1111 | actor=actor, |
| 1112 | ) |
| 1113 | |
| 1114 | async def get_recall_memory_summary(self, agent_id: str, actor: Client) -> RecallMemorySummary: |
| 1115 | size = await self.message_manager.size(actor=actor, agent_id=agent_id) |
nothing calls this directly
no test coverage detected