Struct Workflow 

pub struct Workflow<I, O> { /* private fields */ }

A workflow is a collection of tasks that can be executed by a worker, often forming a directed acyclic graph (DAG). See Hatchet.workflow() for more information.

Implementations

impl<I, O> Workflow<I, O>

where I: Serialize + Send + Sync, O: DeserializeOwned + Send + Sync,

pub fn add_task<P>(self, task: &Task<I, P>) -> Self

where I: DeserializeOwned + Send + 'static, P: Serialize + Send + 'static,

pub async fn schedule( &self, trigger_at: DateTime<Utc>, input: &I, options: Option<&ScheduleOptions>, ) -> Result<ScheduledRun, HatchetError>

Schedule this workflow to run at a specific future time. See SchedulesClient::create for the underlying API.

pub async fn cron( &self, name: &str, expression: &str, input: &I, options: Option<&CronOptions>, ) -> Result<CronTrigger, HatchetError>

Create a recurring cron trigger for this workflow. See CronsClient::create for the underlying API.

Trait Implementations

impl<I: Clone, O: Clone> Clone for Workflow<I, O>

fn clone(&self) -> Workflow<I, O>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<I, O> Register<Workflow<I, O>, I, O> for Worker

where I: Serialize + Send + Sync + 'static, O: DeserializeOwned + Send + Sync + 'static,

fn add_task_or_workflow(self, workflow: &Workflow<I, O>) -> Self

impl<I, O> Runnable<I, O> for Workflow<I, O>

where I: Serialize + Send + Sync + DeserializeOwned + 'static, O: DeserializeOwned + Send + Sync + 'static,

fn get_run<'life0, 'life1, 'async_trait>( &'life0 self, run_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<GetWorkflowRunResponse, HatchetError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn run_no_wait<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, input: &'life1 I, options: Option<&'life2 TriggerWorkflowOptions>, ) -> Pin<Box<dyn Future<Output = Result<String, HatchetError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

fn run<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, input: &'life1 I, options: Option<&'life2 TriggerWorkflowOptions>, ) -> Pin<Box<dyn Future<Output = Result<O, HatchetError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,