chnjinlei/hive
1
0
Fork 0
Code Issues Pull Requests Actions 41 Packages Projects Releases Wiki Activity

fix: queen session and node registry

Browse Source
This commit is contained in:
Richard Tang
2026-04-03 09:11:33 -07:00
parent a164ed6faf
commit 51fdd93f0c
7 changed files with 54 additions and 138 deletions
Download Patch File Download Diff File Expand all files Collapse all files
core/tests/test_event_loop_node.py
+4 -5
View File
@@ -1556,7 +1556,7 @@ class TestOutputAccumulator:
assert acc.has_all_keys(["key1", "key2"]) is True
@pytest.mark.asyncio
async def test_run_scoped_cursor_state(self, tmp_path):
async def test_flat_cursor_state(self, tmp_path):
store = FileConversationStore(tmp_path / "acc_runs")
acc_a = OutputAccumulator(store=store, run_id="run-a")
acc_b = OutputAccumulator(store=store, run_id="run-b")
@@ -1564,11 +1564,10 @@ class TestOutputAccumulator:
await acc_a.set("result", "alpha")
await acc_b.set("result", "beta")
restored_a = await OutputAccumulator.restore(store, run_id="run-a")
restored_b = await OutputAccumulator.restore(store, run_id="run-b")
restored = await OutputAccumulator.restore(store)
assert restored_a.get("result") == "alpha"
assert restored_b.get("result") == "beta"
# Flat cursor: last write wins regardless of run_id
assert restored.get("result") == "beta"
# ===========================================================================