(
&self,
event_tx: &Option<mpsc::Sender<AgentEvent>>,
session_id: &str,
plan: &ExecutionPlan,
)
| 23 | } |
| 24 | |
| 25 | pub(super) async fn emit_task_updated( |
| 26 | &self, |
| 27 | event_tx: &Option<mpsc::Sender<AgentEvent>>, |
| 28 | session_id: &str, |
| 29 | plan: &ExecutionPlan, |
| 30 | ) { |
| 31 | if let Some(tx) = event_tx { |
| 32 | tx.send(AgentEvent::TaskUpdated { |
| 33 | session_id: session_id.to_string(), |
| 34 | tasks: plan.steps.clone(), |
| 35 | }) |
| 36 | .await |
| 37 | .ok(); |
| 38 | } |
| 39 | } |
| 40 | |
| 41 | /// Create an execution plan for a prompt |
| 42 | /// |
no test coverage detected