Skip to main content

Interruptible

atomr_agents_workflow

Struct Interruptible

pub struct Interruptible {
    pub workflow_id: WorkflowId,
    pub run_id: RunId,
    pub dag: Dag<Arc<dyn InterruptibleStep>>,
    pub schema: Arc<StateSchema>,
    pub checkpointer: Arc<dyn Checkpointer>,
    pub interrupt_before: HashSet<StepId>,
    pub interrupt_after: HashSet<StepId>,
}

Fields§

§workflow_id: WorkflowId§run_id: RunId§dag: Dag<Arc<dyn InterruptibleStep>>§schema: Arc<StateSchema>§checkpointer: Arc<dyn Checkpointer>§interrupt_before: HashSet<StepId>§interrupt_after: HashSet<StepId>

Implementations§

impl Interruptible

pub async fn run(&self) -> Result<RunOutcome>

pub async fn resume(&self, command: Command) -> Result<RunOutcome>

Resume from the most recent paused checkpoint.

Auto Trait Implementations§

impl Freeze for Interruptible

impl !RefUnwindSafe for Interruptible

impl Send for Interruptible

impl Sync for Interruptible

impl Unpin for Interruptible

impl UnsafeUnpin for Interruptible

impl !UnwindSafe for Interruptible

Blanket Implementations§

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

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more

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

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more

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

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

Mutably borrows from an owned value. Read more

impl<T> From<T> for T

fn from(t: T) -> T

Returns the argument unchanged.

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

fn into(self) -> U

Calls U::from(self).

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

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

type Error = Infallible

The type returned in the event of a conversion error.

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

Performs the conversion.

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

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

The type returned in the event of a conversion error.

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

Performs the conversion.