Deploy f4d188a

app/pipeline/nodes/log_eval.py

@@ -178,7 +178,7 @@ def make_log_eval_node(db_path: str) -> Callable[[PipelineState], dict]:
             "source_hit_proxy": _source_hit_proxy(state),
         }
 
-    def log_eval_node(state: PipelineState) -> dict:
+    async def log_eval_node(state: PipelineState) -> dict:
         try:
             row_id = _write_to_sqlite(state)
             try:

tests/test_axiom_sink.py

@@ -156,7 +156,7 @@ async def test_source_hit_proxy_logged_to_sqlite(tmp_path) -> None:
         "follow_ups": [],
     }
 
-    result = node(state)
+    result = await node(state)
     assert "interaction_id" in result
 
     with sqlite3.connect(db_path) as conn:

tests/test_log_eval_privacy.py

@@ -7,7 +7,8 @@ import pytest
 from app.pipeline.nodes.log_eval import _PENDING_TASKS, make_log_eval_node
 
 
-def test_log_eval_stores_chunk_metadata_without_text(tmp_path) -> None:
+@pytest.mark.asyncio
+async def test_log_eval_stores_chunk_metadata_without_text(tmp_path) -> None:
     db_path = str(tmp_path / "interactions.db")
     node = make_log_eval_node(db_path)
 
@@ -33,7 +34,7 @@ def test_log_eval_stores_chunk_metadata_without_text(tmp_path) -> None:
         "is_enumeration_query": False,
     }
 
-    node(state)
+    await node(state)
 
     with sqlite3.connect(db_path) as conn:
         row = conn.execute("SELECT reranked_chunks_json FROM interactions LIMIT 1").fetchone()
@@ -57,7 +58,7 @@ async def test_log_eval_sends_sanitized_axiom_payload(monkeypatch, tmp_path) ->
 
     monkeypatch.setattr("app.pipeline.nodes.log_eval.ship_to_axiom", _fake_ship_to_axiom)
 
-    node(
+    await node(
         {
             "session_id": "s1",
             "query": "What work experience does Darshan have?",