Struct CreateScheduleRequest 

pub struct CreateScheduleRequest {
    pub workflow_name: String,
    pub cron_expression: String,
    pub inputs: Value,
    pub priority: Option<i16>,
    pub catchup: Option<CatchupPolicy>,
    pub catchup_max: Option<u32>,
    pub catchup_window_secs: Option<u32>,
    pub overlap: Option<OverlapPolicy>,
    pub timezone: Option<Tz>,
}

Create schedule request body.

Fields

workflow_name: String

Name of the workflow to trigger.

cron_expression: String

Cron expression (6-field format, e.g. "0 */5 * * * *").

inputs: Value

JSON payload for the workflow. Defaults to {}.

priority: Option<i16>

Queue priority given to every run the schedule creates, from -100 to 100. Defaults to the priority the workflow handler declares.

A higher priority run is picked first by workers. A running run is never preempted, and a low priority run is not aged.

catchup: Option<CatchupPolicy>

What the schedule does with the occurrences it missed while no server fired it: latest (default) runs the most recent one, all runs each of them, skip runs none.

catchup_max: Option<u32>

Most runs created to catch up under catchup = all, from 1 to 1000. Defaults to 10.

catchup_window_secs: Option<u32>

How far back, in seconds, a missed occurrence is still caught up, from 60 to 2592000 (30 days). Defaults to 86400 (one day).

overlap: Option<OverlapPolicy>

What the schedule does when an occurrence comes while one of its runs is still active: allow (default) starts another run, skip drops the occurrence.

timezone: Option<Tz>

IANA timezone the cron expression is evaluated in, e.g. "Europe/Paris". Defaults to "UTC".

Trait Implementations

impl Debug for CreateScheduleRequest

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for CreateScheduleRequest

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Validate for CreateScheduleRequest

fn validate(&self) -> Result<(), ValidationErrors>

impl<'v_a> ValidateArgs<'v_a> for CreateScheduleRequest

type Args = ()

fn validate_with_args(&self, args: Self::Args) -> Result<(), ValidationErrors>