Don't validate state machine when executing a Map or Parallel state

Author: nibble-4bits

src/stateMachine/StateMachine.ts

@@ -35,14 +35,16 @@ export class StateMachine {
    * These options also apply to state machines defined in the `Iterator` field of `Map` states and in the `Branches` field of `Parallel` states.
    */
   constructor(definition: StateMachineDefinition, stateMachineOptions?: StateMachineOptions) {
-    const { isValid, errorsText } = aslValidator(definition, {
-      checkArn: true,
-      checkPaths: true,
-      ...stateMachineOptions?.validationOptions,
-    });
-
-    if (!isValid) {
-      throw new Error(`State machine definition is invalid, see error(s) below:\n ${errorsText('\n')}`);
+    if (!stateMachineOptions?.validationOptions?._noValidate) {
+      const { isValid, errorsText } = aslValidator(definition, {
+        checkArn: true,
+        checkPaths: true,
+        ...stateMachineOptions?.validationOptions,
+      });
+
+      if (!isValid) {
+        throw new Error(`State machine definition is invalid, see error(s) below:\n ${errorsText('\n')}`);
+      }
     }
 
     this.definition = definition;

src/stateMachine/stateActions/MapStateAction.ts

@@ -71,7 +71,10 @@ class MapStateAction extends BaseStateAction<MapState> {
       throw new StatesRuntimeError('Input of Map state must be an array or ItemsPath property must point to an array');
     }
 
-    const iteratorStateMachine = new StateMachine(state.Iterator, options?.stateMachineOptions);
+    const iteratorStateMachine = new StateMachine(state.Iterator, {
+      ...options?.stateMachineOptions,
+      validationOptions: { _noValidate: true },
+    });
     const limit = pLimit(state.MaxConcurrency || DEFAULT_MAX_CONCURRENCY);
     const processedItemsPromise = items.map((item, i) =>
       limit(() => this.processItem(iteratorStateMachine, item, input, context, i, options))

src/stateMachine/stateActions/ParallelStateAction.ts

@@ -27,7 +27,10 @@ class ParallelStateAction extends BaseStateAction<ParallelState> {
     context: Context,
     options: ParallelStateActionOptions | undefined
   ): Promise<JSONValue> {
-    const stateMachine = new StateMachine(branch, options?.stateMachineOptions);
+    const stateMachine = new StateMachine(branch, {
+      ...options?.stateMachineOptions,
+      validationOptions: { _noValidate: true },
+    });
     const execution = stateMachine.run(input, options?.runOptions);
 
     this.executionAbortFuncs.push(execution.abort);

src/typings/StateMachineImplementation.ts

@@ -18,6 +18,10 @@ interface Overrides {
 export interface ValidationOptions {
   readonly checkPaths?: boolean;
   readonly checkArn?: boolean;
+  /**
+   * @internal DO NOT USE. This property is meant for internal use only.
+   */
+  readonly _noValidate?: boolean;
 }
 
 export interface AWSConfig {

tsconfig.json

@@ -5,7 +5,8 @@
     "declaration": true,
     "noUncheckedIndexedAccess": false,
     "noUnusedParameters": false,
-    "resolveJsonModule": true
+    "resolveJsonModule": true,
+    "stripInternal": true
   },
   "include": ["src/**/*.ts"],
   "exclude": ["node_modules"]