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

Method with_step_events

core/src/orchestration/workflow.rs:138–141  ·  view source on GitHub ↗

Thread the per-step [`AgentEvent`] sender into every combinator call so existing subagent/AHP/trace listeners observe child-run lifecycle events.

(mut self, step_events: broadcast::Sender<AgentEvent>)

Source from the content-addressed store, hash-verified

136 /// Thread the per-step [`AgentEvent`] sender into every combinator call so
137 /// existing subagent/AHP/trace listeners observe child-run lifecycle events.
138 pub fn with_step_events(mut self, step_events: broadcast::Sender<AgentEvent>) -> Self {
139 self.step_events = Some(step_events);
140 self
141 }
142
143 /// Set the stable root id used to derive per-phase checkpoint keys. Supply a
144 /// deterministic id (e.g. session-derived) for resume to work across runs;

Callers 1

Calls

no outgoing calls

Tested by

no test coverage detected