Apply ruff formatting to 11 files

Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>

Author: 2 people

examples/healer_matching.py

@@ -33,11 +33,13 @@ def match_healer(patient_query: str) -> None:
             strategy="matching",
             max_context_tokens=1000,
         )
-        matches.append({
-            "character": healer,
-            "context": ctx,
-            "token_estimate": ctx.token_estimate,
-        })
+        matches.append(
+            {
+                "character": healer,
+                "context": ctx,
+                "token_estimate": ctx.token_estimate,
+            }
+        )
 
     # Sort by context richness (more relevant profile = better match)
     matches.sort(key=lambda m: m["token_estimate"], reverse=True)

hippodid/_http.py

@@ -124,7 +124,9 @@ def request(
 
             except (httpx.ConnectError, httpx.ReadTimeout) as exc:
                 if attempt >= self._max_retries:
-                    raise HippoDidError(f"Connection failed after {self._max_retries} retries: {exc}")
+                    raise HippoDidError(
+                        f"Connection failed after {self._max_retries} retries: {exc}"
+                    )
                 time.sleep(backoff)
                 attempt += 1
                 backoff *= 2
@@ -162,7 +164,9 @@ def request_multipart(
 
             except (httpx.ConnectError, httpx.ReadTimeout) as exc:
                 if attempt >= self._max_retries:
-                    raise HippoDidError(f"Connection failed after {self._max_retries} retries: {exc}")
+                    raise HippoDidError(
+                        f"Connection failed after {self._max_retries} retries: {exc}"
+                    )
                 time.sleep(backoff)
                 attempt += 1
                 backoff *= 2

hippodid/_strategies.py

@@ -113,14 +113,11 @@ def assemble_conversational(
     sorted_results = sorted(
         enumerate(results),
         key=lambda pair: (
-            pair[1].relevance_score * (1.0 - recency_weight)
-            + (1.0 - pair[0] / n) * recency_weight
+            pair[1].relevance_score * (1.0 - recency_weight) + (1.0 - pair[0] / n) * recency_weight
         ),
         reverse=True,
     )
-    memories = _format_memories_by_relevance(
-        [r for _, r in sorted_results], max_context_tokens
-    )
+    memories = _format_memories_by_relevance([r for _, r in sorted_results], max_context_tokens)
 
     prompt_parts = []
     if system_prompt:
@@ -132,8 +129,7 @@ def assemble_conversational(
         )
     if memories:
         prompt_parts.append(
-            f"\n## Recent Context & Memories\n"
-            f"Draw on these naturally in conversation:\n{memories}"
+            f"\n## Recent Context & Memories\nDraw on these naturally in conversation:\n{memories}"
         )
 
     formatted = "\n".join(prompt_parts)
@@ -179,8 +175,7 @@ def assemble_task_focused(
 
     if memories:
         prompt_parts.append(
-            f"\n## Relevant Context\n"
-            f"Use these facts to inform your work:\n{memories}"
+            f"\n## Relevant Context\nUse these facts to inform your work:\n{memories}"
         )
 
     formatted = "\n".join(prompt_parts)

hippodid/async_client.py

@@ -106,9 +106,7 @@ async def get_character(self, character_id: str) -> Character:
         return Character.model_validate(await self._get(f"/v1/characters/{character_id}"))
 
     async def get_character_by_external_id(self, external_id: str) -> Character:
-        return Character.model_validate(
-            await self._get(f"/v1/characters/external/{external_id}")
-        )
+        return Character.model_validate(await self._get(f"/v1/characters/external/{external_id}"))
 
     async def list_characters(
         self,
@@ -214,9 +212,7 @@ async def search_memories(
         body: Dict[str, Any] = {"query": query, "topK": top_k}
         if categories:
             body["categories"] = categories
-        data = await self._post(
-            f"/v1/characters/{character_id}/memories/search", json=body
-        )
+        data = await self._post(f"/v1/characters/{character_id}/memories/search", json=body)
         return [SearchResult.model_validate(r) for r in data.get("results", [])]
 
     async def get_memories(
@@ -493,9 +489,7 @@ async def set_agent_config(
     async def delete_agent_config(self, character_id: str) -> None:
         await self._delete(f"/v1/characters/{character_id}/agent-config")
 
-    async def create_agent_config_template(
-        self, name: str, **kwargs: Any
-    ) -> AgentConfigTemplate:
+    async def create_agent_config_template(self, name: str, **kwargs: Any) -> AgentConfigTemplate:
         body = {
             "name": name,
             "config": {

hippodid/client.py

@@ -103,9 +103,7 @@ def get_character(self, character_id: str) -> Character:
         return Character.model_validate(self._get(f"/v1/characters/{character_id}"))
 
     def get_character_by_external_id(self, external_id: str) -> Character:
-        return Character.model_validate(
-            self._get(f"/v1/characters/external/{external_id}")
-        )
+        return Character.model_validate(self._get(f"/v1/characters/external/{external_id}"))
 
     def list_characters(
         self,
@@ -144,9 +142,7 @@ def update_character(
             body["description"] = description
         if memory_mode is not None:
             body["memoryMode"] = memory_mode
-        return Character.model_validate(
-            self._put(f"/v1/characters/{character_id}", json=body)
-        )
+        return Character.model_validate(self._put(f"/v1/characters/{character_id}", json=body))
 
     def delete_character(self, character_id: str) -> None:
         self._delete(f"/v1/characters/{character_id}")
@@ -337,9 +333,7 @@ def create_character_template(
             body["defaultValues"] = default_values
         if field_mappings is not None:
             body["fieldMappings"] = field_mappings
-        return CharacterTemplate.model_validate(
-            self._post("/v1/templates/characters", json=body)
-        )
+        return CharacterTemplate.model_validate(self._post("/v1/templates/characters", json=body))
 
     def list_character_templates(self) -> List[CharacterTemplate]:
         data = self._get("/v1/templates/characters")
@@ -380,9 +374,7 @@ def update_character_template(
     def delete_character_template(self, template_id: str) -> None:
         self._delete(f"/v1/templates/characters/{template_id}")
 
-    def preview_character_template(
-        self, template_id: str, sample_row: Dict[str, str]
-    ) -> Character:
+    def preview_character_template(self, template_id: str, sample_row: Dict[str, str]) -> Character:
         return Character.model_validate(
             self._post(
                 f"/v1/templates/characters/{template_id}/preview",
@@ -419,7 +411,9 @@ def batch_create_characters(
             raise TypeError(f"data must be a list of dicts or pandas DataFrame, got {type(data)}")
 
         csv_bytes = self._rows_to_csv(rows)
-        return self._upload_batch(template_id, csv_bytes, "data.csv", external_id_column, on_conflict, dry_run)
+        return self._upload_batch(
+            template_id, csv_bytes, "data.csv", external_id_column, on_conflict, dry_run
+        )
 
     def batch_create_from_file(
         self,
@@ -433,7 +427,9 @@ def batch_create_from_file(
         with open(file_path, "rb") as f:
             file_bytes = f.read()
         filename = file_path.rsplit("/", 1)[-1] if "/" in file_path else file_path
-        return self._upload_batch(template_id, file_bytes, filename, external_id_column, on_conflict, dry_run)
+        return self._upload_batch(
+            template_id, file_bytes, filename, external_id_column, on_conflict, dry_run
+        )
 
     def get_batch_job_status(self, job_id: str) -> BatchJob:
         return BatchJob.model_validate(self._get(f"/v1/jobs/{job_id}"))
@@ -474,9 +470,7 @@ def _rows_to_csv(rows: List[Dict[str, str]]) -> bytes:
     # ═════════════════════════════════════════════════════════════════════════
 
     def get_agent_config(self, character_id: str) -> AgentConfig:
-        return AgentConfig.model_validate(
-            self._get(f"/v1/characters/{character_id}/agent-config")
-        )
+        return AgentConfig.model_validate(self._get(f"/v1/characters/{character_id}/agent-config"))
 
     def set_agent_config(
         self,
@@ -599,9 +593,7 @@ def ask(
             body["category"] = category
         if use_agent_config:
             body["useAgentConfig"] = True
-        return AskResult.model_validate(
-            self._post(f"/v1/characters/{character_id}/ask", json=body)
-        )
+        return AskResult.model_validate(self._post(f"/v1/characters/{character_id}/ask", json=body))
 
     # ═════════════════════════════════════════════════════════════════════════
     # Assemble Context (client-side)
@@ -632,8 +624,7 @@ def assemble_context(
         strategy_fn = STRATEGIES.get(strategy)
         if strategy_fn is None:
             raise ValueError(
-                f"Unknown strategy '{strategy}'. "
-                f"Available: {', '.join(STRATEGIES.keys())}"
+                f"Unknown strategy '{strategy}'. Available: {', '.join(STRATEGIES.keys())}"
             )
 
         return strategy_fn(character, results, max_context_tokens, recency_weight)

tests/test_agent_config.py

@@ -47,9 +47,7 @@ def test_set_agent_config(client, mock_api):
 
 
 def test_delete_agent_config(client, mock_api):
-    mock_api.delete(f"/v1/characters/{CID}/agent-config").mock(
-        return_value=httpx.Response(204)
-    )
+    mock_api.delete(f"/v1/characters/{CID}/agent-config").mock(return_value=httpx.Response(204))
     client.delete_agent_config(CID)
 
 

tests/test_assemble_context.py

@@ -65,10 +65,12 @@ def test_assemble_context_token_budget():
     character = _make_character()
     # Create many results to exceed budget
     results = [
-        SearchResult.model_validate({
-            **SEARCH_RESULT_JSON,
-            "content": f"Memory fact number {i} with some extra text to increase size " * 5,
-        })
+        SearchResult.model_validate(
+            {
+                **SEARCH_RESULT_JSON,
+                "content": f"Memory fact number {i} with some extra text to increase size " * 5,
+            }
+        )
         for i in range(50)
     ]
 
@@ -82,11 +84,13 @@ def test_assemble_context_token_budget():
 def test_assemble_context_recency_weight():
     character = _make_character()
     results = [
-        SearchResult.model_validate({
-            **SEARCH_RESULT_JSON,
-            "content": f"Memory {i}",
-            "relevanceScore": 0.5 + (i * 0.05),
-        })
+        SearchResult.model_validate(
+            {
+                **SEARCH_RESULT_JSON,
+                "content": f"Memory {i}",
+                "relevanceScore": 0.5 + (i * 0.05),
+            }
+        )
         for i in range(10)
     ]
 
@@ -142,5 +146,6 @@ def test_unknown_strategy_raises(client, mock_api):
         return_value=httpx.Response(200, json={"results": [], "count": 0})
     )
     import pytest
+
     with pytest.raises(ValueError, match="Unknown strategy"):
         client.assemble_context(CID, "test", strategy="nonexistent")

tests/test_batch_create.py

@@ -10,9 +10,7 @@
 
 
 def test_get_batch_job_status(client, mock_api):
-    mock_api.get(f"/v1/jobs/{JID}").mock(
-        return_value=httpx.Response(200, json=BATCH_JOB_JSON)
-    )
+    mock_api.get(f"/v1/jobs/{JID}").mock(return_value=httpx.Response(200, json=BATCH_JOB_JSON))
     job = client.get_batch_job_status(JID)
     assert job.status == "COMPLETED"
     assert job.progress.total == 10
@@ -22,6 +20,7 @@ def test_get_batch_job_status(client, mock_api):
 
 def test_rows_to_csv():
     from hippodid.client import HippoDid
+
     rows = [
         {"name": "Alice", "role": "Engineer"},
         {"name": "Bob", "role": "Manager"},
@@ -35,11 +34,13 @@ def test_rows_to_csv():
 
 def test_rows_to_csv_empty():
     from hippodid.client import HippoDid
+
     assert HippoDid._rows_to_csv([]) == b""
 
 
 def test_batch_create_validates_data_type(client):
     import pytest
+
     with pytest.raises(TypeError, match="list of dicts"):
         client.batch_create_characters(TID, "not-a-list", "id_col")
 

tests/test_character_crud.py

@@ -6,9 +6,7 @@
 
 
 def test_create_character(client, mock_api):
-    mock_api.post("/v1/characters").mock(
-        return_value=httpx.Response(201, json=CHARACTER_JSON)
-    )
+    mock_api.post("/v1/characters").mock(return_value=httpx.Response(201, json=CHARACTER_JSON))
     char = client.create_character(name="Ada", description="A test character")
     assert char.name == "Ada"
     assert char.id == "c1000000-0000-0000-0000-000000000001"
@@ -45,18 +43,14 @@ def test_list_characters(client, mock_api):
 def test_update_character(client, mock_api):
     cid = "c1000000-0000-0000-0000-000000000001"
     updated = {**CHARACTER_JSON, "name": "Ada v2"}
-    mock_api.put(f"/v1/characters/{cid}").mock(
-        return_value=httpx.Response(200, json=updated)
-    )
+    mock_api.put(f"/v1/characters/{cid}").mock(return_value=httpx.Response(200, json=updated))
     char = client.update_character(cid, name="Ada v2")
     assert char.name == "Ada v2"
 
 
 def test_delete_character(client, mock_api):
     cid = "c1000000-0000-0000-0000-000000000001"
-    mock_api.delete(f"/v1/characters/{cid}").mock(
-        return_value=httpx.Response(204)
-    )
+    mock_api.delete(f"/v1/characters/{cid}").mock(return_value=httpx.Response(204))
     client.delete_character(cid)  # should not raise
 
 

tests/test_memory_ops.py

@@ -65,7 +65,5 @@ def test_update_memory(client, mock_api):
 
 def test_delete_memory(client, mock_api):
     mid = "m2000000-0000-0000-0000-000000000001"
-    mock_api.delete(f"/v1/characters/{CID}/memories/{mid}").mock(
-        return_value=httpx.Response(204)
-    )
+    mock_api.delete(f"/v1/characters/{CID}/memories/{mid}").mock(return_value=httpx.Response(204))
     client.delete_memory(CID, mid)