mirror of
https://github.com/razzant/ouroboros.git
synced 2026-10-03 04:07:04 +00:00
f4c6d5200b
Full parallel battery caught two classes the targeted runs missed: - five more test files hand-writing task-result rows as current-version writers (subagent_final_lineage, continuation_authority_bounds, route_to_project, promote_chat_flow, doc_context) now stamp them. - the ABI-5 deadline-alias sweep checker gains ONE documented exemption: ouroboros/task_result_schema.py spells the retired until_deadline token as the refusal comparison that quarantines stored contracts still carrying it (the removal's enforcement arm, ledger f30 entry 4) - a refusal, not a resurrected alias. (cherry picked from commit 3eafd0f327247c7f0bb54b9758dcf16ec711250c)
190 lines
8.4 KiB
Python
190 lines
8.4 KiB
Python
"""Focused continuation-authority regressions for terminal provenance."""
|
|
|
|
from __future__ import annotations
|
|
|
|
import json
|
|
from types import SimpleNamespace
|
|
|
|
|
|
def _authority_source(task_id: str) -> dict:
|
|
return {
|
|
"kind": "task_result",
|
|
"task_id": task_id,
|
|
"tool": "get_task_result",
|
|
"arguments": {"task_id": task_id, "include_authority": True},
|
|
}
|
|
|
|
|
|
def _write_result(root, row: dict) -> None:
|
|
result_dir = root / "task_results"
|
|
result_dir.mkdir(exist_ok=True)
|
|
(result_dir / f"{row['task_id']}.json").write_text(
|
|
json.dumps({"_schema_version": 1, **row}), encoding="utf-8",
|
|
)
|
|
|
|
|
|
def test_host_salvage_automatic_authority_is_bounded_but_explicit_read_is_full(
|
|
tmp_path,
|
|
):
|
|
from ouroboros.agent_startup_checks import (
|
|
_AUTOMATIC_HOST_SALVAGE_RESULT_CHARS,
|
|
task_result_authority_projection,
|
|
validate_task_authority_sources,
|
|
)
|
|
from ouroboros.tools.control import _get_task_result
|
|
from ouroboros.tools.registry import ToolContext
|
|
|
|
task_id = "failed-predecessor"
|
|
tail = "FULL_SALVAGE_TAIL_REMAINS_EXPLICITLY_READABLE"
|
|
full_result = "unreviewed provider output\n" + (
|
|
"x" * (_AUTOMATIC_HOST_SALVAGE_RESULT_CHARS + 5_000)
|
|
) + tail
|
|
row = {
|
|
"task_id": task_id,
|
|
"status": "failed",
|
|
"reason_code": "provider_unavailable",
|
|
"terminal_origin": "host_salvage",
|
|
"result": full_result,
|
|
"outcome_axes": {"objective": "best_effort", "process": "failed"},
|
|
}
|
|
_write_result(tmp_path, row)
|
|
source = _authority_source(task_id)
|
|
task = {
|
|
"id": "continuation",
|
|
"budget_drive_root": str(tmp_path),
|
|
"predecessor_authority_source": source,
|
|
}
|
|
env = SimpleNamespace(drive_root=tmp_path, budget_drive_root=tmp_path)
|
|
|
|
assert validate_task_authority_sources(env, task) == {}
|
|
automatic = task["predecessor_authority"]
|
|
result = automatic["result"]
|
|
assert result["kind"] == "unreviewed_host_salvage"
|
|
assert len(result["preview"]) <= _AUTOMATIC_HOST_SALVAGE_RESULT_CHARS
|
|
assert result["full_chars"] >= len(full_result) # serialized chars
|
|
assert result["source_ref"] == {**source, "field": "authority.result"}
|
|
# The carried prefix is byte-exact and SUBSTANTIAL - a preview carrying a
|
|
# token prefix plus a marker would pass a startswith(200) check while
|
|
# discarding the budget it promises.
|
|
carried = len(result["preview"].split("\n\u26a0", 1)[0])
|
|
assert carried > _AUTOMATIC_HOST_SALVAGE_RESULT_CHARS - 1_000
|
|
assert result["preview"].startswith(full_result[:carried])
|
|
assert "OMISSION NOTE" in result["preview"]
|
|
assert tail not in json.dumps(automatic)
|
|
assert len(json.dumps(automatic)) < 25_000
|
|
# The bounded continuation envelope (delegation-usefulness, owner
|
|
# 2026-08-30): identity + digest + pull source instead of the recursive
|
|
# full-body copy that compiled 300K+ work orders.
|
|
assert automatic["kind"] == "bounded_continuation_envelope"
|
|
assert automatic["authority_chars"] > len(full_result)
|
|
assert len(automatic["authority_sha256"]) == 64
|
|
assert automatic["status"] == "failed"
|
|
assert automatic["reason_code"] == "provider_unavailable"
|
|
assert automatic["outcome_axes"] == row["outcome_axes"]
|
|
nested_contract = automatic.get("task_contract") or {}
|
|
assert "predecessor_authority" not in nested_contract, "no recursion carrier"
|
|
|
|
# The shared projection and the explicit tool remain full. Only startup's
|
|
# automatic predecessor injection is narrowed.
|
|
assert task_result_authority_projection(row)["result"] == full_result
|
|
explicit = json.loads(_get_task_result(
|
|
ToolContext(
|
|
repo_dir=tmp_path,
|
|
drive_root=tmp_path,
|
|
budget_drive_root=str(tmp_path),
|
|
),
|
|
task_id,
|
|
include_authority=True,
|
|
))
|
|
assert explicit["authority"]["result"] == full_result
|
|
assert tail in explicit["authority"]["result"]
|
|
|
|
|
|
def test_automatic_authority_rides_whole_or_pointer(tmp_path):
|
|
"""Decoupled contract (delegation-usefulness, owner 2026-08-30): the
|
|
automatic predecessor injection is a bounded envelope for EVERY origin.
|
|
A result that fits one ordinary tool-result budget rides whole (no pull
|
|
round for small hops); a bigger one rides as a bounded preview beside the
|
|
named pull source - the full body stays in task_results, explicitly
|
|
readable (the sibling salvage test pins that half)."""
|
|
from ouroboros.agent_startup_checks import (
|
|
_AUTOMATIC_HOST_SALVAGE_RESULT_CHARS,
|
|
validate_task_authority_sources,
|
|
)
|
|
|
|
env = SimpleNamespace(drive_root=tmp_path, budget_drive_root=tmp_path)
|
|
small_result = "concise model answer"
|
|
big_result = "complete model answer\n" + (
|
|
"m" * (_AUTOMATIC_HOST_SALVAGE_RESULT_CHARS + 5_000)
|
|
)
|
|
for task_id, full_result in (("model-small", small_result), ("model-big", big_result)):
|
|
_write_result(tmp_path, {
|
|
"task_id": task_id, "status": "completed", "result": full_result,
|
|
"terminal_origin": "model_final",
|
|
})
|
|
task = {
|
|
"id": f"continue-{task_id}",
|
|
"budget_drive_root": str(tmp_path),
|
|
"predecessor_authority_source": _authority_source(task_id),
|
|
}
|
|
assert validate_task_authority_sources(env, task) == {}
|
|
automatic = task["predecessor_authority"]
|
|
assert automatic["kind"] == "bounded_continuation_envelope"
|
|
if full_result is small_result:
|
|
assert automatic["result"] == full_result, "small hops ride whole"
|
|
else:
|
|
assert automatic["result"]["kind"] == "bounded_field_preview"
|
|
# full_chars counts the SERIALIZED body (escapes included).
|
|
assert automatic["result"]["full_chars"] >= len(full_result)
|
|
preview = automatic["result"]["preview"]
|
|
carried = len(preview.split("\n\u26a0", 1)[0])
|
|
assert carried > _AUTOMATIC_HOST_SALVAGE_RESULT_CHARS - 1_000
|
|
assert preview.startswith(full_result[:carried])
|
|
assert "OMISSION NOTE" in preview
|
|
|
|
|
|
def test_legacy_collapse_fires_only_on_growth_carriers_and_is_idempotent():
|
|
"""build_task_contract collapses a legacy predecessor body only when it
|
|
carries growth - a nested recursion carrier or an oversized string.
|
|
Bounded bodies ride byte-identical (exact strings are authority), and a
|
|
collapsed envelope survives a rebuild untouched."""
|
|
from ouroboros.contracts.task_contract import build_task_contract
|
|
|
|
bounded = {
|
|
"source": {"kind": "task_result", "task_id": "flat"},
|
|
"result": "small durable answer",
|
|
"task_contract": {"objective": "carry on"},
|
|
}
|
|
contract = build_task_contract({"objective": "next", "predecessor_authority": bounded})
|
|
assert contract["predecessor_authority"] == bounded, "no growth - no re-dressing"
|
|
|
|
fat = {
|
|
"source": {"kind": "task_result", "task_id": "deep"},
|
|
"result": "r" * 25_000,
|
|
"capability_delta": {"granted": ["net"]},
|
|
"task_contract": {
|
|
"objective": "grandparent objective",
|
|
"predecessor_authority": {
|
|
"result": "grandparent body",
|
|
"source": {"kind": "task_result", "task_id": "grandpa"},
|
|
},
|
|
},
|
|
}
|
|
contract = build_task_contract({"objective": "next", "predecessor_authority": fat})
|
|
envelope = contract["predecessor_authority"]
|
|
assert envelope["kind"] == "bounded_continuation_envelope"
|
|
assert envelope["collapsed_from"] == "legacy_full_body"
|
|
assert "predecessor_authority" not in envelope["task_contract"], "recursion carrier dropped"
|
|
assert envelope["task_contract"]["objective"] == "grandparent objective"
|
|
assert envelope["capability_delta"] == {"granted": ["net"]}, "compact facts inherit"
|
|
preview = envelope["result"]
|
|
assert preview["kind"] == "bounded_field_preview"
|
|
assert preview["full_chars"] == 25_000 and "OMISSION NOTE" in preview["preview"]
|
|
assert preview["source_ref"]["task_id"] == "deep", "the pull route is named"
|
|
assert envelope["source"] == fat["source"], "the pull route survives"
|
|
assert envelope["previous_task_id"] == "grandpa", (
|
|
"the cursor names the hop BEFORE this body's subject - the binding "
|
|
"rule - never the subject's own id (a self-loop)")
|
|
|
|
again = build_task_contract({"objective": "next-hop", "predecessor_authority": envelope})
|
|
assert again["predecessor_authority"] == envelope, "envelope rebuild is a no-op"
|