Struct ScheduleActivityRequest 

pub struct ScheduleActivityRequest {
    pub name: String,
    pub seq: i32,
    pub task_queue: String,
    pub input: Option<Value>,
    pub max_attempts: Option<i32>,
    pub initial_interval_secs: Option<f64>,
    pub backoff_coefficient: Option<f64>,
    pub start_to_close_secs: Option<f64>,
    pub heartbeat_timeout_secs: Option<f64>,
}

Fields

name: String

Activity name (the worker matches this to a registered handler)

seq: i32

Sequence number relative to the workflow. Used for idempotency: scheduling the same (workflow_id, seq) twice is a no-op on the second call. Workflows assign sequence numbers in execution order.

task_queue: String

Task queue to route the activity to (workers poll a specific queue)

input: Option<Value>

JSON-serialisable input passed to the activity handler

max_attempts: Option<i32>

Maximum attempts before the activity is marked FAILED (default 3)

initial_interval_secs: Option<f64>

Initial retry backoff in seconds (default 1.0)

backoff_coefficient: Option<f64>

Exponential backoff coefficient (default 2.0)

start_to_close_secs: Option<f64>

Total time the activity has to complete before being failed (default 300)

heartbeat_timeout_secs: Option<f64>

If set, an activity that hasn’t heartbeated within this window is auto-failed

Trait Implementations

impl ComposeSchema for ScheduleActivityRequest

fn compose(generics: Vec<RefOr<Schema>>) -> RefOr<Schema>

impl<'de> Deserialize<'de> for ScheduleActivityRequest

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl ToSchema for ScheduleActivityRequest

fn name() -> Cow<'static, str>

Return name of the schema.

fn schemas(schemas: &mut Vec<(String, RefOr<Schema>)>)

Implement reference utoipa::openapi::schema::Schemas for this type.