pub struct TaskRunner { /* private fields */ }Expand description
Task runner configuration.
Implementations§
Source§impl TaskRunner
impl TaskRunner
pub fn new(repo: String) -> Self
Sourcepub fn with_store(self, store: Arc<TaskStore>) -> Self
pub fn with_store(self, store: Arc<TaskStore>) -> Self
Set the unified task store for run audit trail.
Sourcepub async fn run(
&self,
task_id: &str,
agent: Option<&str>,
model: Option<&str>,
backend: Option<&dyn ExternalBackend>,
started_at: &DateTime<Utc>,
) -> Result<Option<RunExecution>>
pub async fn run( &self, task_id: &str, agent: Option<&str>, model: Option<&str>, backend: Option<&dyn ExternalBackend>, started_at: &DateTime<Utc>, ) -> Result<Option<RunExecution>>
Run a task through the full execution pipeline.
Returns Ok(None) if the runner guard skipped the task (caller should not
post stale results). Returns Ok(Some(status)) with the final task status.
Sourcepub async fn run_with_context(
&self,
task: &ExternalTask,
backend: &Arc<dyn ExternalBackend>,
_tmux: &Arc<TmuxManager>,
route_result: Option<&RouteResult>,
) -> Result<WeightSignal>
pub async fn run_with_context( &self, task: &ExternalTask, backend: &Arc<dyn ExternalBackend>, _tmux: &Arc<TmuxManager>, route_result: Option<&RouteResult>, ) -> Result<WeightSignal>
Run a task with full engine context (backend, tmux, capture).
Called by the engine dispatch loop with richer context.
Returns a WeightSignal for the engine to feed back to the router.
Auto Trait Implementations§
impl !RefUnwindSafe for TaskRunner
impl !UnwindSafe for TaskRunner
impl Freeze for TaskRunner
impl Send for TaskRunner
impl Sync for TaskRunner
impl Unpin for TaskRunner
impl UnsafeUnpin for TaskRunner
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
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self> ⓘ
fn instrument(self, span: Span) -> Instrumented<Self> ⓘ
Source§fn in_current_span(self) -> Instrumented<Self> ⓘ
fn in_current_span(self) -> Instrumented<Self> ⓘ
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self> ⓘ
fn into_either(self, into_left: bool) -> Either<Self, Self> ⓘ
Converts
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self> ⓘ
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self> ⓘ
Converts
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read more