AWS Step Functions Workflow Examples You Can Run Locally

Adverse Event Reporting

Handles the detection and escalation of adverse events in a clinical trial. It validates the sample, enforces a brief Wait to allow upstream systems to settle, then runs concurrent safety and eligibility checks using a Parallel state before notifying investigators or triggering a critical alert.

Batch Payment Settlement

Processes an array of payments concurrently using a Map state. Each payment is independently validated, fraud-checked, authorized, and settled in parallel. Results are collected into a single batch summary with per-payment status records.

Booking Amendment

This workflow handles the end-to-end amendment of a previously confirmed freight booking. It validates the amendment request, enforces a mandatory processing hold using a Wait state, then runs concurrent carrier capacity re-check and hazmat re-verification using a Parallel state before issuing a confirmed amendment or cancellation.

Bulk Booking Processing

This workflow processes an array of freight bookings concurrently using a Map state with a maximum concurrency of 3. Each booking is independently subjected to carrier capacity checks and hazmat screening in parallel branches before being individually confirmed or cancelled.

Bulk Component Inspection

Processes a batch of manufacturing components concurrently using a Map state with a maximum concurrency of 3. Each component set is independently validated, inspected, partially assembled, and structurally tested before sub-system certification.

Bulk Content Ingest

Processes a batch of content items concurrently using a Map state (up to 5 at a time). Each item is independently validated, moderation-screened, and license-checked in parallel branches before being queued for transcoding or rejected.

Bulk Content Moderation

Batch content moderation using a Map state with MaxConcurrency 3. Supports large-scale content queue processing and retroactive moderation sweeps.

Bulk Document Ingestion

Batch ingestion of multiple documents concurrently using a Map state. Supports scheduled full-corpus re-ingestion and large document library imports.

Bulk Meter Processing

Processes an array of smart meter readings concurrently using a Map state. Each reading is independently validated, usage-calculated, and anomaly-checked before bill generation or flagging for manual review.

Bulk Model Retraining

Batch retraining of multiple models concurrently using a Map state. Supports scheduled monthly retraining runs across all production models.

Bulk Order Processing

Processes a batch of vehicle orders concurrently using a Map state, with a maximum concurrency of 3. Each order in the batch is independently validated and screened for inventory availability and credit eligibility in parallel branches before being confirmed or rejected.

Bulk Outage Processing

Processes a batch of active outage events concurrently using a Map state with a maximum concurrency of 3. Each outage is independently validated, root-cause diagnosed, and impact-assessed before field dispatch and rerouting are initiated.