Les erreurs arrivent. Les réseaux tombent, les API renvoient des 500, les Mind Keys\nexpirent. Ce guide montre comment les agents LLM devraient gérer les erreurs\ngracieusement et en tirer des leçons.
\nimport time\nimport requests\n\ndef call_with_retry(url, max_retries=3, backoff_base=2):\n """Call URL with exponential backoff."""\n for attempt in range(max_retries):\n try:\n r = requests.get(url, headers={"Authorization": f"Bearer {KEY}"})\n \n # Succès\n if r.status_code < 400:\n return r\n \n # Limité en débit — attendre et réessayer\n if r.status_code == 429:\n wait = int(r.headers.get("Retry-After", 60))\n print(f"Rate limited. Waiting {wait}s...")\n time.sleep(wait)\n continue\n \n # Erreur serveur — réessayer avec backoff\n if r.status_code >= 500:\n wait = backoff_base ** attempt\n print(f"Server error {r.status_code}. Retrying in {wait}s...")\n time.sleep(wait)\n continue\n \n # Erreur client — ne pas réessayer\n if 400 <= r.status_code < 500:\n raise ClientError(f"{r.status_code}: {r.text}")\n \n except requests.RequestException as e:\n # Erreur réseau — réessayer\n wait = backoff_base ** attempt\n print(f"Network error: {e}. Retrying in {wait}s...")\n time.sleep(wait)\n \n raise MaxRetriesError(f"Failed after {max_retries} retries")def safe_call(url):\n """Call with auth error handling."""\n try:\n return call_with_retry(url)\n except ClientError as e:\n if "401" in str(e):\n # Mind Key invalide — critique, impossible à récupérer\n store_error("auth_invalid", str(e), "Check Mind Key")\n notify_human("My Mind Key is invalid. Please update.")\n raise AuthError("Cannot continue without valid Mind Key")\n elif "403" in str(e):\n store_error("forbidden", str(e), "Wrong token type?")\n raise ForbiddenError(str(e))\n elif "404" in str(e):\n # Le chemin n'existe pas — ne pas réessayer\n store_error("not_found", str(e), "Check endpoint path")\n raise NotFoundError(str(e))\n else:\n raiseQuand des erreurs se produisent, stockez-les pour que les futures sessions puissent\napprendre :
\ndef store_error(error_type, error_message, recovery_hint=""):\n """Store an error as a memory for future reference."""\n requests.post(f"{URL}/memory",\n headers={"Authorization": f"Bearer {KEY}",\n "Content-Type": "application/json"},\n json={\n "category": "mistake",\n "key": f"error_{error_type}_{int(time.time())}",\n "content": f"Error: {error_type}\\nMessage: {error_message}\\nRecovery: {recovery_hint}",\n "tags": ["error", error_type],\n "priority": "high"\n })\n\n# Exemple\ntry:\n deploy()\nexcept DeployError as e:\n store_error("deploy_failed", str(e), \n "Check CI logs, verify Docker image exists")\n raise# Détection : 401 sur chaque appel\n# Récupération : Impossible — nécessite une intervention humaine\n\ndef handle_invalid_mind_key():\n store_error("mind_key_invalid", \n "All API calls returning 401",\n "Mind Key may be revoked. Need new key.")\n \n # Notifier l'humain via chat (si possible)\n try:\n reply("⚠️ My Mind Key is invalid. I cannot access memories. "\n "Please check and update SYNAPSE_MIND_KEY.")\n except:\n pass # Le chat peut aussi échouer avec une mauvaise clé\n \n # Sortir gracieusement\n raise CriticalError("Cannot continue without valid Mind Key")# Détection : ConnectionError, Timeout\n# Récupération : Réessayer avec backoff, puis dégrader\n\ndef handle_network_error(url, retry=3):\n for attempt in range(retry):\n try:\n return requests.get(url, timeout=10)\n except (requests.ConnectionError, requests.Timeout) as e:\n wait = 2 ** attempt\n print(f"Network error, retrying in {wait}s: {e}")\n time.sleep(wait)\n \n # Tous les essais échoués — dégrader\n store_error("network_failure", \n f"Cannot reach {url}",\n "Check internet connection, Synapse may be down")\n \n # Travailler hors ligne si possible\n return work_offline()# Détection : 429 avec en-tête Retry-After\n# Récupération : Attendre et réessayer, ou passer à l'auth par en-tête\n\ndef handle_rate_limit(response):\n retry_after = int(response.headers.get("Retry-After", 60))\n print(f"Rate limited. Waiting {retry_after}s...")\n time.sleep(retry_after)\n \n # Si cela continue, suggérer de passer à l'auth par en-tête\n if has_query_param_auth(url):\n store_error("rate_limited", \n "Frequent 429s with ?key= auth",\n "Switch to Authorization: Bearer header (no rate limit)")# Détection : 500, 502, 503\n# Récupération : Réessayer avec backoff, vérifier /health\n\ndef handle_server_error(url):\n # Vérifier si le serveur fonctionne\n health = requests.get(f"{URL}/health")\n if health.status_code != 200:\n store_error("server_down", \n "Synapse health check failing",\n "Wait for server recovery")\n raise ServerDownError()\n \n # Réessayer avec backoff\n return call_with_retry(url, max_retries=5)# Détection : L'outil renvoie un contenu d'erreur\n# Récupération : Essayer une approche alternative, stocker l'échec\n\ndef call_tool_safely(tool_name, args, alternatives=None):\n try:\n result = call_tool(tool_name, args)\n if result.get("isError"):\n raise ToolError(result["content"])\n return result\n except ToolError as e:\n store_error(f"tool_{tool_name}_failed",\n f"Args: {args}\\nError: {e}",\n f"Try: {alternatives or 'no alternatives'}")\n \n # Essayer des alternatives\n if alternatives:\n for alt in alternatives:\n try:\n return call_tool(alt, args)\n except:\n continue\n \n raisePour les échecs répétés, arrêter d'essayer temporairement :
\nclass CircuitBreaker:\n def __init__(self, threshold=5, reset_time=300):\n self.failures = 0\n self.threshold = threshold\n self.reset_time = reset_time\n self.last_failure = 0\n \n def call(self, fn, *args, **kwargs):\n if self.failures >= self.threshold:\n if time.time() - self.last_failure < self.reset_time:\n raise CircuitOpenError("Circuit breaker open")\n else:\n # Réinitialiser\n self.failures = 0\n \n try:\n result = fn(*args, **kwargs)\n self.failures = 0 # Réinitialiser sur succès\n return result\n except:\n self.failures += 1\n self.last_failure = time.time()\n raise\n\n# Utilisation\nbreaker = CircuitBreaker(threshold=5)\ntry:\n result = breaker.call(api_call, url)\nexcept CircuitOpenError:\n print("Too many failures, waiting before retry")