diagnose D1 timeout class

d1_client.py

@@ -43,5 +43,5 @@ async def execute_sql(sql: str, params: Optional[list[Any]] = None) -> list[dict
                 return []
             return data["result"][0].get("results", [])
         except Exception as e:
-            print(f"🔴 D1 Connection Error: {e}")
+            print(f"🔴 D1 Connection Error [{type(e).__name__}]: {e}")
             return []

test_d1_client.py

@@ -0,0 +1,37 @@
+import asyncio
+import unittest
+from contextlib import redirect_stdout
+from io import StringIO
+from unittest.mock import patch
+
+import httpx
+import d1_client
+
+
+class _RaisingClient:
+    async def __aenter__(self):
+        return self
+
+    async def __aexit__(self, exc_type, exc, tb):
+        return False
+
+    async def post(self, *args, **kwargs):
+        raise httpx.ReadTimeout('')
+
+
+class D1ClientDiagnosticsTests(unittest.TestCase):
+    def test_timeout_log_includes_exception_type(self):
+        output = StringIO()
+        with patch.object(d1_client, 'ACCOUNT_ID', 'acct'), \
+             patch.object(d1_client, 'DATABASE_ID', 'db'), \
+             patch.object(d1_client, 'API_TOKEN', 'token'), \
+             patch.object(d1_client.httpx, 'AsyncClient', return_value=_RaisingClient()), \
+             redirect_stdout(output):
+            result = asyncio.run(d1_client.execute_sql('SELECT 1'))
+
+        self.assertEqual(result, [])
+        self.assertIn('ReadTimeout', output.getvalue())
+
+
+if __name__ == '__main__':
+    unittest.main()