(params: RunLifecycleParams)
| 122 | } |
| 123 | |
| 124 | fn run_lifecycle_event(params: RunLifecycleParams) -> a3s_ahp::AhpEvent { |
| 125 | let updated_at = now(); |
| 126 | let payload = a3s_ahp::RunLifecycleEvent { |
| 127 | run_id: params.run_id.to_string(), |
| 128 | session_id: params.session_id.to_string(), |
| 129 | status: params.status, |
| 130 | prompt: params.prompt, |
| 131 | result_summary: params.result_summary, |
| 132 | error: params.error, |
| 133 | started_at: None, |
| 134 | updated_at, |
| 135 | metadata: None, |
| 136 | }; |
| 137 | ahp_event( |
| 138 | a3s_ahp::EventType::RunLifecycle, |
| 139 | params.session_id, |
| 140 | params.agent_id, |
| 141 | params.depth, |
| 142 | serde_json::to_value(payload).expect("run lifecycle payload serializes"), |
| 143 | ) |
| 144 | } |
| 145 | |
| 146 | fn task_list_event( |
| 147 | run_id: &str, |
no test coverage detected