Merge pull request #645 from tnfssc/chore/deescalate-some-errors

This commit is contained in:
Sharath 2025-06-05 17:37:17 +05:30 committed by GitHub
commit a1d5ed00cb
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
2 changed files with 4 additions and 4 deletions

View File

@ -578,8 +578,8 @@ class ResponseProcessor:
logger.info("Stream cost calculation resulted in zero or None, not storing cost message.")
self.trace.update(metadata={"cost": 0})
except Exception as e:
logger.error(f"Error calculating final cost for stream: {str(e)}")
self.trace.event(name="error_calculating_final_cost_for_stream", level="ERROR", status_message=(f"Error calculating final cost for stream: {str(e)}"))
logger.warning(f"Failed to calculate final cost for stream: {str(e)}")
self.trace.event(name="failed_to_calculate_final_cost_for_stream", level="WARNING", status_message=(f"Failed to calculate final cost for stream: {str(e)}"))
# --- Final Finish Status ---
@ -1069,7 +1069,7 @@ class ResponseProcessor:
"arguments": params # The extracted parameters
}
logger.debug(f"Created tool call: {tool_call}")
# logger.debug(f"Created tool call: {tool_call}")
return tool_call, parsing_details # Return both dicts
except Exception as e:

View File

@ -235,7 +235,7 @@ async def run_agent_background(
# Wait for all pending redis operations to complete, with timeout
try:
await asyncio.wait_for(asyncio.gather(*pending_redis_operations), timeout=5.0)
await asyncio.wait_for(asyncio.gather(*pending_redis_operations), timeout=30.0)
except asyncio.TimeoutError:
logger.warning(f"Timeout waiting for pending Redis operations for {agent_run_id}")