klbr/khoj
1
0
Fork 0
mirror of https://github.com/khoaliber/khoj.git synced 2026-03-02 13:18:18 +00:00
Code Issues Packages Projects Releases Wiki Activity

Handle failed operator agent calls to anthropic api more gracefully

Browse Source 
Add anthropic operator api call errors to trajectory instead of
erroring out of current operator run
This commit is contained in:
Debanjum
2025-05-28 00:33:30 -07:00
parent d54bfc19e5
commit b027024c42
1 changed files with 30 additions and 20 deletions
Download Patch File Download Diff File Expand all files Collapse all files

50
src/khoj/processor/operator/operator_agent_anthropic.py
View File

@@ -66,22 +66,31 @@ class AnthropicOperatorAgent(OperatorAgent):
self.messages = primary_task + condensed_trajectory + recent_trajectory
messages_for_api = self._format_message_for_api(self.messages)
response = await client.beta.messages.create(
messages=messages_for_api,
model=self.vision_model.name,
system=system_prompt,
tools=tools,
betas=betas,
thinking=thinking,
max_tokens=4096, # TODO: Make configurable?
temperature=temperature,
)
try:
response = await client.beta.messages.create(
messages=messages_for_api,
model=self.vision_model.name,
system=system_prompt,
tools=tools,
betas=betas,
thinking=thinking,
max_tokens=4096, # TODO: Make configurable?
temperature=temperature,
)
response_content = response.content
except Exception as e:
# create a response block with error message
logger.error(f"Error during Anthropic API call: {e}")
error_str = e.message if hasattr(e, "message") else str(e)
response = None
response_content = [BetaTextBlock(text=f"Communication Error: {error_str}", type="text")]
else:
logger.debug(f"Anthropic response: {response.model_dump_json()}")
logger.debug(f"Anthropic response: {response.model_dump_json()}")
self.messages.append(AgentMessage(role="assistant", content=response.content))
rendered_response = self._render_response(response.content, current_state.screenshot)
self.messages.append(AgentMessage(role="assistant", content=response_content))
rendered_response = self._render_response(response_content, current_state.screenshot)
for block in response.content:
for block in response_content:
if block.type == "tool_use":
content = None
is_error = False
@@ -184,12 +193,13 @@ class AnthropicOperatorAgent(OperatorAgent):
}
)
self._update_usage(
response.usage.input_tokens,
response.usage.output_tokens,
response.usage.cache_read_input_tokens,
response.usage.cache_creation_input_tokens,
)
if response:
self._update_usage(
response.usage.input_tokens,
response.usage.output_tokens,
response.usage.cache_read_input_tokens,
response.usage.cache_creation_input_tokens,
)
self.tracer["temperature"] = temperature
return AgentActResult(