Skip to main content

workflow

Macro workflow 

Source
workflow!() { /* proc-macro */ }
Expand description

Builds a workflow pipeline with a concise DSL.

§Syntax

workflow!("workflow-id", CodecType, registry_expr,
    step => step => step
)

§Step Types

  • task_name — reference to a #[task]-generated struct
  • name(param: Type) { expr } — inline task
  • step || step — parallel fork (branches)
  • delay "5s" — durable delay (auto-generated ID)
  • delay "wait_24h" "5s" — durable delay with custom ID
  • => — sequential chain (or join after ||)

§Returns

A Result<SerializableWorkflow<C, Input, ()>, WorkflowError> expression.