Skip to content

Commit 0092ffc

Browse files
committed
fix: preserve finalize schema-failure handling
1 parent 8eaba02 commit 0092ffc

1 file changed

Lines changed: 16 additions & 3 deletions

File tree

apps/orchestrator/src/cortexpilot_orch/scheduler/scheduler_bridge_finalize.py

Lines changed: 16 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -519,9 +519,22 @@ def _queue_follow_up_contract(
519519
"suggested_action": str(continuation_decision.get("selected_action") or "none"),
520520
"notes": str(continuation_decision.get("summary") or "n/a"),
521521
}
522-
report_validator.validate_report(final_task_result, "task_result.v1.json")
523-
store.write_report(run_id, "task_result", final_task_result)
524-
store.write_task_result(run_id, task_id, final_task_result)
522+
try:
523+
report_validator.validate_report(final_task_result, "task_result.v1.json")
524+
except Exception as exc: # noqa: BLE001
525+
failure_reason = failure_reason or f"task_result schema invalid: {exc}"
526+
status = "FAILURE"
527+
append_gate_failed_fn(
528+
store,
529+
run_id,
530+
"schema_validation",
531+
str(exc),
532+
schema="task_result.v1.json",
533+
path="reports/task_result.json",
534+
)
535+
else:
536+
store.write_report(run_id, "task_result", final_task_result)
537+
store.write_task_result(run_id, task_id, final_task_result)
525538
store.write_report(run_id, "completion_governance_report", completion_governance_report)
526539
store.append_event(
527540
run_id,

0 commit comments

Comments
 (0)