Download for macOS today, or join the waitlist for Windows and Linux.
Workflows / Automotive

Bulk Recall Processing

This workflow processes a batch of affected vehicles concurrently using a Map state with a maximum concurrency of 3. For each vehicle, owner notification and parts ordering are run simultaneously in a Parallel state before scheduling the inspection appointment.

Clone

GitHub icon View on Github 
{
  "Comment": "Bulk recall processing: iterates over a batch of affected vehicles concurrently (Map, MaxConcurrency 3). For each vehicle, owner notification and parts ordering run simultaneously (Parallel) before the inspection is scheduled.",
  "StartAt": "ProcessAffectedVehicleBatch",
  "States": {
    "ProcessAffectedVehicleBatch": {
      "Type": "Map",
      "Comment": "Process each affected vehicle in the batch concurrently, up to 3 at a time.",
      "ItemsPath": "$.vehicles",
      "MaxConcurrency": 3,
      "ItemProcessor": {
        "ProcessorConfig": {
          "Mode": "INLINE"
        },
        "StartAt": "ValidateVehicleRecord",
        "States": {
          "ValidateVehicleRecord": {
            "Type": "Task",
            "Resource": "arn:aws:states:::lambda:invoke",
            "Parameters": {
              "FunctionName": "${ValidateRecallFunctionArn}",
              "Payload.$": "$"
            },
            "ResultPath": "$.validation",
            "Retry": [
              {
                "ErrorEquals": [
                  "Lambda.ServiceException",
                  "Lambda.AWSLambdaException",
                  "Lambda.SdkClientException"
                ],
                "IntervalSeconds": 2,
                "MaxAttempts": 2,
                "BackoffRate": 2
              }
            ],
            "Catch": [
              {
                "ErrorEquals": [
                  "States.ALL"
                ],
                "ResultPath": "$.error",
                "Next": "ItemValidationError"
              }
            ],
            "Next": "IsVehicleRecordValid"
          },
          "IsVehicleRecordValid": {
            "Type": "Choice",
            "Choices": [
              {
                "Variable": "$.validation.Payload.isValid",
                "BooleanEquals": true,
                "Next": "NotifyAndOrderParts"
              }
            ],
            "Default": "SkipInvalidRecord"
          },
          "SkipInvalidRecord": {
            "Type": "Succeed"
          },
          "ItemValidationError": {
            "Type": "Fail",
            "Error": "ValidationError",
            "Cause": "Recall validation lambda failed unexpectedly"
          },
          "NotifyAndOrderParts": {
            "Type": "Parallel",
            "Comment": "Notify vehicle owner and order replacement parts simultaneously.",
            "Branches": [
              {
                "StartAt": "NotifyVehicleOwner",
                "States": {
                  "NotifyVehicleOwner": {
                    "Type": "Task",
                    "Resource": "arn:aws:states:::lambda:invoke",
                    "Parameters": {
                      "FunctionName": "${NotifyOwnerFunctionArn}",
                      "Payload.$": "$.validation.Payload"
                    },
                    "End": true
                  }
                }
              },
              {
                "StartAt": "OrderPartsForVehicle",
                "States": {
                  "OrderPartsForVehicle": {
                    "Type": "Task",
                    "Resource": "arn:aws:states:::lambda:invoke",
                    "Parameters": {
                      "FunctionName": "${OrderReplacementPartsFunctionArn}",
                      "Payload.$": "$.validation.Payload"
                    },
                    "End": true
                  }
                }
              }
            ],
            "ResultPath": "$.parallel",
            "Next": "ScheduleVehicleInspection"
          },
          "ScheduleVehicleInspection": {
            "Type": "Task",
            "Resource": "arn:aws:states:::lambda:invoke",
            "Parameters": {
              "FunctionName": "${ScheduleInspectionFunctionArn}",
              "Payload.$": "$.validation.Payload"
            },
            "ResultPath": "$.inspection",
            "End": true
          }
        }
      },
      "ResultPath": "$.processedVehicles",
      "End": true
    }
  }
}
JSON
Expand
100%

Automotive teams can use patterns like this to build reliable, compliant, and scalable automation for payment systems and can test and refine these flows locally with Thrubit to reduce cloud cost and speed up iteration.

Related Workflows

More Automotive Workflows from Vehicle Recall Management

Vehicle Recall Pipeline

Automotive
This workflow models a complete end-to-end vehicle recall management pipeline using AWS Step Functions. It validates the recall notice, identifies affected vehicles, notifies registered owners, schedules dealership inspections, orders replacement parts, records regulatory compliance, and closes the recall case.

Recall Escalation

Automotive
This workflow handles escalation of a recall case where an initial inspection or parts order has failed. It re-validates the recall, enforces a brief processing Wait, then re-runs owner notification and parts ordering in parallel before re-scheduling inspection or closing the case with an escalation flag.

Express Vehicle Check

Automotive
This workflow provides a fast recall eligibility check for a single VIN. It identifies whether the vehicle is affected, and if so immediately schedules a dealership inspection, applying a brief Wait to allow appointment confirmation to propagate before completing with a Succeed or Fail terminal state.
Free Trial