pub struct TeamRunner { /* private fields */ }Expand description
Binds an AgentTeam to concrete AgentExecutor sessions, enabling
Lead → Worker → Reviewer automated workflows.
Implementations§
Source§impl TeamRunner
impl TeamRunner
Sourcepub fn bind_session(
&mut self,
member_id: &str,
executor: Arc<dyn AgentExecutor>,
) -> Result<()>
pub fn bind_session( &mut self, member_id: &str, executor: Arc<dyn AgentExecutor>, ) -> Result<()>
Bind an executor to a team member.
Returns an error if member_id is not registered in the team.
Sourcepub fn task_board(&self) -> Arc<TeamTaskBoard>
pub fn task_board(&self) -> Arc<TeamTaskBoard>
Access the shared task board.
Sourcepub async fn run_until_done(&self, goal: &str) -> Result<TeamRunResult>
pub async fn run_until_done(&self, goal: &str) -> Result<TeamRunResult>
Run the full Lead → Worker → Reviewer workflow until all tasks are done
or max_rounds is exceeded.
Steps:
- Lead decomposes
goalinto tasks via JSON response. - Workers concurrently claim and execute tasks.
- Reviewer approves or rejects completed tasks.
- Rejected tasks re-enter the work queue for retry.
Trait Implementations§
Auto Trait Implementations§
impl Freeze for TeamRunner
impl !RefUnwindSafe for TeamRunner
impl Send for TeamRunner
impl Sync for TeamRunner
impl Unpin for TeamRunner
impl UnsafeUnpin for TeamRunner
impl !UnwindSafe for TeamRunner
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more