Skip to main content

ExecutorContext

Struct ExecutorContext 

Source
pub struct ExecutorContext {
    pub input: HandlerInput,
    pub submission: Option<Arc<dyn TaskSubmissionPort>>,
    pub children: Option<ChildrenSnapshot>,
}
Expand description

Full execution context provided to a handler for each attempt.

Extends HandlerInput with optional workflow extensions:

§Cancellation contract

See HandlerInput for the timeout and cancellation contract.

Fields§

§input: HandlerInput

Core execution input: identifiers, payload, metadata, cancellation.

§submission: Option<Arc<dyn TaskSubmissionPort>>

Optional channel for proposing new child tasks during execution.

Present when the workflow feature is active. Handlers set parent_task_id on submitted TaskSpecs to establish hierarchy.

§children: Option<ChildrenSnapshot>

Optional snapshot of child task states, taken at dispatch time.

Present when the dispatched task has children in the hierarchy tracker. Coordinator handlers use this to check progress and decide what to submit.

Trait Implementations§

Source§

impl Debug for ExecutorContext

Source§

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter. Read more

Auto Trait Implementations§

Blanket Implementations§

Source§

impl<T> Any for T
where T: 'static + ?Sized,

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
Source§

impl<T> Borrow<T> for T
where T: ?Sized,

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

Source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

Source§

impl<T, U> Into<U> for T
where U: From<T>,

Source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

Source§

type Error = Infallible

The type returned in the event of a conversion error.
Source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
Source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

Source§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
Source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.