fix(stepfunctions-tasks): RUN_JOB integration pattern not supported f…

…or CallAwsService It is only supported for AWS Batch and Amazon ECS. Throw when used for CallAwsService. Closes #19174
aws · Feb 28, 2022 · 0e2d97b · 0e2d97b
1 parent 3f49f02
commit 0e2d97b
Show file tree

Hide file tree

Showing 2 changed files with 17 additions and 0 deletions.
diff --git a/packages/@aws-cdk/aws-stepfunctions-tasks/lib/aws-sdk/call-aws-service.ts b/packages/@aws-cdk/aws-stepfunctions-tasks/lib/aws-sdk/call-aws-service.ts
@@ -64,6 +64,10 @@ export class CallAwsService extends sfn.TaskStateBase {
   constructor(scope: Construct, id: string, private readonly props: CallAwsServiceProps) {
     super(scope, id, props);
 
+    if (this.props.integrationPattern === sfn.IntegrationPattern.RUN_JOB) {
+      throw new Error('The RUN_JOB integration pattern is not supported for CallAwsService');
+    }
+
     this.taskPolicies = [
       new iam.PolicyStatement({
         resources: props.iamResources,

diff --git a/packages/@aws-cdk/aws-stepfunctions-tasks/test/aws-sdk/call-aws-service.test.ts b/packages/@aws-cdk/aws-stepfunctions-tasks/test/aws-sdk/call-aws-service.test.ts
@@ -146,3 +146,16 @@ test('with unresolved tokens', () => {
     Parameters: {},
   });
 });
+
+test('throws with invalid integration pattern', () => {
+  expect(() => new tasks.CallAwsService(stack, 'GetObject', {
+    integrationPattern: sfn.IntegrationPattern.RUN_JOB,
+    service: 's3',
+    action: 'getObject',
+    parameters: {
+      Bucket: 'my-bucket',
+      Key: sfn.JsonPath.stringAt('$.key'),
+    },
+    iamResources: ['*'],
+  })).toThrow(/The RUN_JOB integration pattern is not supported for CallAwsService/);
+});