Struct WorkflowView 

pub struct WorkflowView { /* private fields */ }

The read-only queries of a workflow store, over a QueueView and the MemoStore the runtime writes to. WorkflowRuntime::view returns the runtime’s own view, and a process without a runtime builds a view with WorkflowView::new from a taquba::QueueReader::view and a memo store at the runtime’s prefix.

Implementations

impl WorkflowView

pub fn new(queue: QueueView, memos: MemoStore) -> Self

A view over queue and memos. Through a reader’s view the queries are of the flushed state the reader last observed.

pub async fn status(&self, run_id: &RunId) -> Result<Option<RunStatus>>

The status of run_id from its durable state. An active run is read from the run record, the current-step pointer and the step’s queue job, and a terminated run from its terminal record. A terminated run reports RunState::Terminated until the memo sweep removes its terminal record, and a run that is unknown or swept is None. A run with a pending cancellation request reports RunState::Cancelling at every lifecycle position of its step, until the run terminates.

When a second read returns the current-step pointer with its job still absent, the call fails with Error::InconsistentRunState. The runtime does not write a pointer without its job.

pub async fn outcome(&self, run_id: &RunId) -> Result<Option<RunOutcome>>

The committed outcome of a terminated run, read from its run result record: the result the runner returned or the error that ended the run, with the submitter’s headers and the final step. The record is written by the worker that terminates the run before the terminating settlement and is removed with the run’s memo entries. It is None for a run that is unknown, still active or was terminated without a worker (a cancellation of a pending step, a dead-letter outside the worker), whose status Self::status reports. A record belongs to the termination its terminal record describes: a re-submission of a terminated run id leaves the earlier run’s record in place until its own termination overwrites it, and such a record is not reported.

Trait Implementations

impl Clone for WorkflowView

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.