File tree Expand file tree Collapse file tree
apps/orchestrator/src/cortexpilot_orch/scheduler Expand file tree Collapse file tree Original file line number Diff line number Diff 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 ,
You can’t perform that action at this time.
0 commit comments