MCPcopy Create free account
hub / github.com/AI45Lab/Code / emit_task_updated

Method emit_task_updated

core/src/agent/planning_runtime.rs:25–39  ·  view source on GitHub ↗
(
        &self,
        event_tx: &Option<mpsc::Sender<AgentEvent>>,
        session_id: &str,
        plan: &ExecutionPlan,
    )

Source from the content-addressed store, hash-verified

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 ///

Callers 1

execute_planMethod · 0.80

Calls 2

sendMethod · 0.45
cloneMethod · 0.45

Tested by

no test coverage detected