Struct Task 

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

A task is a unit of work that can be executed by a worker. See Hatchet.task() for more information.

Implementations

impl<I, O> Task<I, O>

where I: Serialize + for<'de> Deserialize<'de> + Send + 'static, O: Serialize + Send + 'static,

pub fn add_parent<J, P>(self, parent: &Task<J, P>) -> Self

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

Schedule this task’s 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 task’s workflow. See CronsClient::create for the underlying API.

Trait Implementations

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

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

Returns a duplicate of the value.

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

Performs copy-assignment from source.

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

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

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

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

where I: Serialize + DeserializeOwned + Send + Sync + 'static, O: Serialize + 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,