style(test): format test helpers

Signed-off-by: phernandez <paul@basicmachines.co>

Author: phernandez

test-int/conftest.py

@@ -178,10 +178,7 @@ async def _reset_postgres_integration_schema(engine) -> None:
             await conn.execute(text(f"DROP TABLE IF EXISTS {table_name} CASCADE"))
 
         await conn.execute(
-            text(
-                f"TRUNCATE TABLE {', '.join(_postgres_reset_tables())} "
-                "RESTART IDENTITY CASCADE"
-            )
+            text(f"TRUNCATE TABLE {', '.join(_postgres_reset_tables())} RESTART IDENTITY CASCADE")
         )
 
 

tests/api/v2/test_knowledge_router_telemetry.py

@@ -59,7 +59,9 @@ async def test_create_entity_emits_root_and_nested_spans(monkeypatch) -> None:
     monkeypatch.setattr(knowledge_router_module.telemetry, "span", fake_span)
 
     entity = _fake_entity()
-    response_content = "---\ntitle: Telemetry Entity\ntype: note\npermalink: notes/test\n---\n\ntelemetry content"
+    response_content = (
+        "---\ntitle: Telemetry Entity\ntype: note\npermalink: notes/test\n---\n\ntelemetry content"
+    )
 
     class FakeEntityService:
         async def create_entity_with_content(self, data):
@@ -119,9 +121,7 @@ async def test_update_entity_emits_root_and_nested_spans(monkeypatch) -> None:
     monkeypatch.setattr(knowledge_router_module.telemetry, "span", fake_span)
 
     entity = _fake_entity()
-    response_content = (
-        "---\ntitle: Telemetry Entity\ntype: note\npermalink: notes/test\n---\n\nupdated telemetry content"
-    )
+    response_content = "---\ntitle: Telemetry Entity\ntype: note\npermalink: notes/test\n---\n\nupdated telemetry content"
 
     class FakeEntityService:
         async def update_entity_with_content(self, existing, data):
@@ -190,9 +190,7 @@ async def test_edit_entity_emits_root_and_nested_spans(monkeypatch) -> None:
     monkeypatch.setattr(knowledge_router_module.telemetry, "span", fake_span)
 
     entity = _fake_entity()
-    response_content = (
-        "---\ntitle: Telemetry Entity\ntype: note\npermalink: notes/test\n---\n\nedited telemetry content"
-    )
+    response_content = "---\ntitle: Telemetry Entity\ntype: note\npermalink: notes/test\n---\n\nedited telemetry content"
 
     class FakeEntityService:
         async def edit_entity_with_content(self, **kwargs):

tests/conftest.py

@@ -172,10 +172,7 @@ async def _reset_postgres_test_schema(engine: AsyncEngine, async_url: str) -> No
             await conn.execute(text(f"DROP TABLE IF EXISTS {table_name} CASCADE"))
 
         await conn.execute(
-            text(
-                f"TRUNCATE TABLE {', '.join(_postgres_reset_tables())} "
-                "RESTART IDENTITY CASCADE"
-            )
+            text(f"TRUNCATE TABLE {', '.join(_postgres_reset_tables())} RESTART IDENTITY CASCADE")
         )
 
         alembic_version_exists = (