vrr/ouroboros
2
0
Fork 0
mirror of https://github.com/razzant/ouroboros.git synced 2026-10-03 04:07:04 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 7

Record definite delegate_answer refusals instead of publishing them as OK

Browse source 
A rejected answer (the engine's typed refusal of the model's own rows, HTTP
or daemon-typed) and an absent run were still returned as ordinary
observations, so a call that provably did not land counted as a successful
call. They now carry the family's envelope: a rejected answer is an agent
fault, an absent run a substrate refusal; delivery_unknown and a successful
observation of a failed run stay what they are. The host codes come from the
family's one owner.

Co-authored-by: Ouroboros <311266734+ouroboros-agent@users.noreply.github.com>
This commit is contained in:
Ouroboros 2026-09-15 23:30:00 +03:00
parent 0d41be0603
commit 2722b7b13b
2 changed files with 26 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

15
ouroboros/delegate_interactions.py
View file

@ -20,7 +20,7 @@ import time
from typing import Any, Dict, List, Optional, Tuple
from ouroboros.delegate_output import _PAYLOAD_ENVELOPE_HEADROOM, _stage_full_output
from ouroboros.delegate_shared import _emit, _fail, _owned_run, delegate_result
from ouroboros.delegate_shared import AGENT_FAULT_CODE, SUBSTRATE_REFUSAL_CODE, _emit, _fail, _owned_run, delegate_result
from ouroboros.tool_capabilities import tool_result_limit
from ouroboros.tools.registry import ToolContext
from ouroboros.tools.tool_result import ToolResult
@ -499,7 +499,7 @@ def _delegate_answer(
# pending and the SAME answers stay valid.
return delegate_result({
"status": "subscription_window_exhausted",
"ok": False, "host_code": "TOOL_REPORTED_FAILURE",
"ok": False, "host_code": SUBSTRATE_REFUSAL_CODE,
"run_id": rid, "interaction_id": iid,
"accepted": False,
"reset_at": str(getattr(exc, "reset_at", "") or "") or None,
@ -523,7 +523,8 @@ def _delegate_answer(
# A bodyless 404 is the daemon's own "no such run" — a definite
# absence, not an ambiguous transport.
return delegate_result({
"status": "not_found", "run_id": rid, "interaction_id": iid,
"status": "not_found", "ok": False, "host_code": SUBSTRATE_REFUSAL_CODE,
"run_id": rid, "interaction_id": iid,
"accepted": False, "detail": str(exc),
"note": _ANSWER_NOTES["not_found"],
})
@ -536,7 +537,10 @@ def _delegate_answer(
# through to delivery_unknown below, whose re-read correctly
# advises retrying the SAME answers while the row is pending.
return delegate_result({
"status": "rejected", "run_id": rid, "interaction_id": iid,
# The engine answered about these bytes: a definite refusal of
# the model's own rows, recorded as the agent fault it is.
"status": "rejected", "ok": False, "host_code": AGENT_FAULT_CODE,
"run_id": rid, "interaction_id": iid,
"accepted": False, "detail": str(exc),
"note": _ANSWER_NOTES["rejected"] + (
f" This was a definite engine refusal (HTTP {status_code}): "
@ -604,6 +608,9 @@ def _delegate_answer(
"detail": str(body.get("message") or ""),
"note": _ANSWER_NOTES.get(status, ""),
}
if status == "rejected":
# The daemon's typed refusal of these rows: an agent fault, recorded.
result.update({"ok": False, "host_code": AGENT_FAULT_CODE})
if source_receipt is not None:
result["work_order_verification"] = source_receipt
return delegate_result(result)

15
tests/test_delegate_answer.py
View file

@ -1031,3 +1031,18 @@ def test_expiry_notes_teach_the_escalation_verb():
"escalated a question to its human",
"goes to your human", "surface it to your human"):
assert phrase not in text, (module.__name__, phrase)
def test_definite_answer_refusals_publish_as_recorded_refusals(tmp_path, monkeypatch):
"""Owner Q8A: a refusal the engine confirmed (rejected rows) is an agent fault,
an absent run a substrate refusal; neither is an OK observation."""
import ouroboros.tools.delegate as delegate
from ouroboros.delegate_shared import AGENT_FAULT_CODE
ctx = _answer_ctx(tmp_path)
_answer_stub(monkeypatch, result={"accepted": False, "status": "rejected", "message": "bad rows"})
_own_run(delegate)
out = delegate._delegate_answer(ctx, "run-1", "int-1", [{"question_id": "q1", "free_text": "x"}])
assert out.code == AGENT_FAULT_CODE and out.status != "ok"
assert json.loads(out.text)["status"] == "rejected"