From 787ed128130da1e2bdc452e6d90c720433972578 Mon Sep 17 00:00:00 2001
From: Shiv Lakshminarayan <shivlaks@amazon.com>
Date: Tue, 2 Feb 2021 01:25:34 -0800
Subject: [PATCH 1/2] docs(stepfunctions-tasks): fix up all code snippets so
 they compile

closes #12606
---
 .../aws-stepfunctions-tasks/README.md         | 265 +++++++-----------
 .../rosetta/default.ts-fixture                |  19 ++
 .../rosetta/with-batch-job.ts-fixture         |  38 +++
 .../rosetta/with-ddb-table.ts-fixture         |  23 ++
 .../rosetta/with-lambda.ts-fixture            |  22 ++
 5 files changed, 202 insertions(+), 165 deletions(-)
 create mode 100644 packages/@aws-cdk/aws-stepfunctions-tasks/rosetta/default.ts-fixture
 create mode 100644 packages/@aws-cdk/aws-stepfunctions-tasks/rosetta/with-batch-job.ts-fixture
 create mode 100644 packages/@aws-cdk/aws-stepfunctions-tasks/rosetta/with-ddb-table.ts-fixture
 create mode 100644 packages/@aws-cdk/aws-stepfunctions-tasks/rosetta/with-lambda.ts-fixture

diff --git a/packages/@aws-cdk/aws-stepfunctions-tasks/README.md b/packages/@aws-cdk/aws-stepfunctions-tasks/README.md
index 80e1dab5ef73f..9fee9cb2618b5 100644
--- a/packages/@aws-cdk/aws-stepfunctions-tasks/README.md
+++ b/packages/@aws-cdk/aws-stepfunctions-tasks/README.md
@@ -99,9 +99,9 @@ of `$` will be used.
 The following example provides the field named `input` as the input to the `Task`
 state that runs a Lambda function.
 
-```ts
-const submitJob = new tasks.LambdaInvoke(stack, 'Invoke Handler', {
-  lambdaFunction: submitJobLambda,
+```ts fixture=with-lambda
+const submitJob = new tasks.LambdaInvoke(this, 'Invoke Handler', {
+  lambdaFunction: fn,
   inputPath: '$.input'
 });
 ```
@@ -119,9 +119,9 @@ as well as other metadata.
 
 The following example assigns the output from the Task to a field named `result`
 
-```ts
-const submitJob = new tasks.LambdaInvoke(stack, 'Invoke Handler', {
-  lambdaFunction: submitJobLambda,
+```ts fixture=with-lambda
+const submitJob = new tasks.LambdaInvoke(this, 'Invoke Handler', {
+  lambdaFunction: fn,
   outputPath: '$.Payload.result'
 });
 ```
@@ -137,10 +137,12 @@ value of `$` will be used.
 The following example adds the item from calling DynamoDB's `getItem` API to the state
 input and passes it to the next state.
 
-```ts
-new tasks.DynamoGetItem(this, 'PutItem', {
-  item: { MessageId: { s: '12345'} },
-  tableName: 'my-table',
+```ts fixture=with-ddb-table
+new tasks.DynamoPutItem(this, 'PutItem', {
+  item: {
+    MessageId: tasks.DynamoAttributeValue.fromString('message-id')
+  },
+  table: myTable,
   resultPath: `$.Item`,
 });
 ```
@@ -160,11 +162,11 @@ using methods such as `JsonPath.stringAt()`.
 The following example provides the field named `input` as the input to the Lambda function
 and invokes it asynchronously.
 
-```ts
-const submitJob = new tasks.LambdaInvoke(stack, 'Invoke Handler', {
-  lambdaFunction: submitJobLambda,
-  payload: sfn.JsonPath.StringAt('$.input'),
-  invocationType: tasks.InvocationType.EVENT,
+```ts fixture=with-lambda
+const submitJob = new tasks.LambdaInvoke(this, 'Invoke Handler', {
+  lambdaFunction: fn,
+  payload: sfn.TaskInput.fromDataAt('$.input'),
+  invocationType: tasks.LambdaInvocationType.EVENT,
 });
 ```
 
@@ -192,7 +194,7 @@ const createMessage = new tasks.EvaluateExpression(this, 'Create message', {
 });
 
 const publishMessage = new tasks.SnsPublish(this, 'Publish message', {
-  topic,
+  topic: new sns.Topic(this, 'cool-topic'),
   message: sfn.TaskInput.fromDataAt('$.message'),
   resultPath: '$.sns',
 });
@@ -223,19 +225,19 @@ Step Functions supports [Athena](https://docs.aws.amazon.com/step-functions/late
 The [StartQueryExecution](https://docs.aws.amazon.com/athena/latest/APIReference/API_StartQueryExecution.html) API runs the SQL query statement.
 
 ```ts
-import * as sfn from '@aws-cdk/aws-stepfunctions';
-import * as tasks from `@aws-cdk/aws-stepfunctions-tasks`;
-
-const startQueryExecutionJob = new tasks.AthenaStartQueryExecution(stack, 'Start Athena Query', {
+const startQueryExecutionJob = new tasks.AthenaStartQueryExecution(this, 'Start Athena Query', {
   queryString: sfn.JsonPath.stringAt('$.queryString'),
   queryExecutionContext: {
-    database: 'mydatabase',
+    databaseName: 'mydatabase',
   },
   resultConfiguration: {
     encryptionConfiguration: {
       encryptionOption: tasks.EncryptionOption.S3_MANAGED,
     },
-    outputLocation: sfn.JsonPath.stringAt('$.outputLocation'),
+    outputLocation: {
+      bucketName: 'query-results-bucket',
+      objectKey: 'folder',
+    },
   },
 });
 ```
@@ -245,10 +247,7 @@ const startQueryExecutionJob = new tasks.AthenaStartQueryExecution(stack, 'Start
 The [GetQueryExecution](https://docs.aws.amazon.com/athena/latest/APIReference/API_GetQueryExecution.html) API gets information about a single execution of a query.
 
 ```ts
-import * as sfn from '@aws-cdk/aws-stepfunctions';
-import * as tasks from `@aws-cdk/aws-stepfunctions-tasks`;
-
-const getQueryExecutionJob = new tasks.AthenaGetQueryExecution(stack, 'Get Query Execution', {
+const getQueryExecutionJob = new tasks.AthenaGetQueryExecution(this, 'Get Query Execution', {
   queryExecutionId: sfn.JsonPath.stringAt('$.QueryExecutionId'),
 });
 ```
@@ -258,10 +257,7 @@ const getQueryExecutionJob = new tasks.AthenaGetQueryExecution(stack, 'Get Query
 The [GetQueryResults](https://docs.aws.amazon.com/athena/latest/APIReference/API_GetQueryResults.html) API that streams the results of a single query execution specified by QueryExecutionId from S3.
 
 ```ts
-import * as sfn from '@aws-cdk/aws-stepfunctions';
-import * as tasks from `@aws-cdk/aws-stepfunctions-tasks`;
-
-const getQueryResultsJob = new tasks.AthenaGetQueryResults(stack, 'Get Query Results', {
+const getQueryResultsJob = new tasks.AthenaGetQueryResults(this, 'Get Query Results', {
   queryExecutionId: sfn.JsonPath.stringAt('$.QueryExecutionId'),
 });
 ```
@@ -271,10 +267,7 @@ const getQueryResultsJob = new tasks.AthenaGetQueryResults(stack, 'Get Query Res
 The [StopQueryExecution](https://docs.aws.amazon.com/athena/latest/APIReference/API_StopQueryExecution.html) API that stops a query execution.
 
 ```ts
-import * as sfn from '@aws-cdk/aws-stepfunctions';
-import * as tasks from `@aws-cdk/aws-stepfunctions-tasks`;
-
-const stopQueryExecutionJob = new tasks.AthenaStopQueryExecution(stack, 'Stop Query Execution', {
+const stopQueryExecutionJob = new tasks.AthenaStopQueryExecution(this, 'Stop Query Execution', {
   queryExecutionId: sfn.JsonPath.stringAt('$.QueryExecutionId'),
 });
 ```
@@ -287,27 +280,7 @@ Step Functions supports [Batch](https://docs.aws.amazon.com/step-functions/lates
 
 The [SubmitJob](https://docs.aws.amazon.com/batch/latest/APIReference/API_SubmitJob.html) API submits an AWS Batch job from a job definition.
 
-```ts
-import * as batch from '@aws-cdk/aws-batch';
-import * as tasks from '@aws-cdk/aws-stepfunctions-tasks';
-
-const batchQueue = new batch.JobQueue(this, 'JobQueue', {
-  computeEnvironments: [
-    {
-      order: 1,
-      computeEnvironment: new batch.ComputeEnvironment(this, 'ComputeEnv', {
-        computeResources: { vpc },
-      }),
-    },
-  ],
-});
-
-const batchJobDefinition = new batch.JobDefinition(this, 'JobDefinition', {
-  container: {
-    image: ecs.ContainerImage.fromAsset(path.resolve(__dirname, 'batchjob-image')),
-  },
-});
-
+```ts fixture=with-batch-job
 const task = new tasks.BatchSubmitJob(this, 'Submit Job', {
   jobDefinition: batchJobDefinition,
   jobName: 'MyJob',
@@ -325,10 +298,8 @@ Step Functions supports [CodeBuild](https://docs.aws.amazon.com/step-functions/l
 
 ```ts
 import * as codebuild from '@aws-cdk/aws-codebuild';
-import * as tasks from '@aws-cdk/aws-stepfunctions-tasks';
-import * as sfn from '@aws-cdk/aws-stepfunctions';
 
-const codebuildProject = new codebuild.Project(stack, 'Project', {
+const codebuildProject = new codebuild.Project(this, 'Project', {
   projectName: 'MyTestProject',
   buildSpec: codebuild.BuildSpec.fromObject({
     version: '0.2',
@@ -342,7 +313,7 @@ const codebuildProject = new codebuild.Project(stack, 'Project', {
   }),
 });
 
-const task = new tasks.CodeBuildStartBuild(stack, 'Task', {
+const task = new tasks.CodeBuildStartBuild(this, 'Task', {
   project: codebuildProject,
   integrationPattern: sfn.IntegrationPattern.RUN_JOB,
   environmentVariablesOverride: {
@@ -363,10 +334,10 @@ Read more about calling DynamoDB APIs [here](https://docs.aws.amazon.com/step-fu
 
 The [GetItem](https://docs.aws.amazon.com/amazondynamodb/latest/APIReference/API_GetItem.html) operation returns a set of attributes for the item with the given primary key.
 
-```ts
+```ts fixture=with-ddb-table
 new tasks.DynamoGetItem(this, 'Get Item', {
   key: { messageId: tasks.DynamoAttributeValue.fromString('message-007') },
-  table,
+  table: myTable,
 });
 ```
 
@@ -374,14 +345,14 @@ new tasks.DynamoGetItem(this, 'Get Item', {
 
 The [PutItem](https://docs.aws.amazon.com/amazondynamodb/latest/APIReference/API_PutItem.html) operation creates a new item, or replaces an old item with a new item.
 
-```ts
+```ts fixture=with-ddb-table
 new tasks.DynamoPutItem(this, 'PutItem', {
   item: {
     MessageId: tasks.DynamoAttributeValue.fromString('message-007'),
     Text: tasks.DynamoAttributeValue.fromString(sfn.JsonPath.stringAt('$.bar')),
     TotalCount: tasks.DynamoAttributeValue.fromNumber(10),
   },
-  table,
+  table: myTable,
 });
 ```
 
@@ -389,13 +360,10 @@ new tasks.DynamoPutItem(this, 'PutItem', {
 
 The [DeleteItem](https://docs.aws.amazon.com/amazondynamodb/latest/APIReference/API_DeleteItem.html) operation deletes a single item in a table by primary key.
 
-```ts
-import * as sfn from '@aws-cdk/aws-stepfunctions';
-import * as tasks from '@aws-cdk/aws-stepfunctions-tasks';
-
+```ts fixture=with-ddb-table
 new tasks.DynamoDeleteItem(this, 'DeleteItem', {
   key: { MessageId: tasks.DynamoAttributeValue.fromString('message-007') },
-  table,
+  table: myTable,
   resultPath: sfn.JsonPath.DISCARD,
 });
 ```
@@ -405,10 +373,12 @@ new tasks.DynamoDeleteItem(this, 'DeleteItem', {
 The [UpdateItem](https://docs.aws.amazon.com/amazondynamodb/latest/APIReference/API_UpdateItem.html) operation edits an existing item's attributes, or adds a new item
 to the table if it does not already exist.
 
-```ts
+```ts fixture=with-ddb-table
 new tasks.DynamoUpdateItem(this, 'UpdateItem', {
-  key: { MessageId: tasks.DynamoAttributeValue.fromString('message-007') },
-  table,
+  key: {
+    MessageId: tasks.DynamoAttributeValue.fromString('message-007')
+  },
+  table: myTable,
   expressionAttributeValues: {
     ':val': tasks.DynamoAttributeValue.numberFromString(sfn.JsonPath.stringAt('$.Item.TotalCount.N')),
     ':rand': tasks.DynamoAttributeValue.fromNumber(20),
@@ -442,20 +412,18 @@ The following example runs a job from a task definition on EC2
 
 ```ts
 import * as ecs from '@aws-cdk/aws-ecs';
-import * as tasks from '@aws-cdk/aws-stepfunctions-tasks';
-import * as sfn from '@aws-cdk/aws-stepfunctions';
 
-const vpc = ec2.Vpc.fromLookup(stack, 'Vpc', {
+const vpc = ec2.Vpc.fromLookup(this, 'Vpc', {
   isDefault: true,
 });
 
-const cluster = new ecs.Cluster(stack, 'Ec2Cluster', { vpc });
+const cluster = new ecs.Cluster(this, 'Ec2Cluster', { vpc });
 cluster.addCapacity('DefaultAutoScalingGroup', {
   instanceType: new ec2.InstanceType('t2.micro'),
   vpcSubnets: { subnetType: ec2.SubnetType.PUBLIC },
 });
 
-const taskDefinition = new ecs.TaskDefinition(stack, 'TD', {
+const taskDefinition = new ecs.TaskDefinition(this, 'TD', {
   compatibility: ecs.Compatibility.EC2,
 });
 
@@ -464,7 +432,7 @@ taskDefinition.addContainer('TheContainer', {
   memoryLimitMiB: 256,
 });
 
-const runTask = new tasks.EcsRunTask(stack, 'Run', {
+const runTask = new tasks.EcsRunTask(this, 'Run', {
     integrationPattern: sfn.IntegrationPattern.RUN_JOB,
     cluster,
     taskDefinition,
@@ -499,16 +467,14 @@ The following example runs a job from a task definition on Fargate
 
 ```ts
 import * as ecs from '@aws-cdk/aws-ecs';
-import * as tasks from '@aws-cdk/aws-stepfunctions-tasks';
-import * as sfn from '@aws-cdk/aws-stepfunctions';
 
-const vpc = ec2.Vpc.fromLookup(stack, 'Vpc', {
+const vpc = ec2.Vpc.fromLookup(this, 'Vpc', {
   isDefault: true,
 });
 
-const cluster = new ecs.Cluster(stack, 'FargateCluster', { vpc });
+const cluster = new ecs.Cluster(this, 'FargateCluster', { vpc });
 
-const taskDefinition = new ecs.TaskDefinition(stack, 'TD', {
+const taskDefinition = new ecs.TaskDefinition(this, 'TD', {
   memoryMiB: '512',
   cpu: '256',
   compatibility: ecs.Compatibility.FARGATE,
@@ -519,7 +485,7 @@ const containerDefinition = taskDefinition.addContainer('TheContainer', {
   memoryLimitMiB: 256,
 });
 
-const runTask = new tasks.EcsRunTask(stack, 'RunFargate', {
+const runTask = new tasks.EcsRunTask(this, 'RunFargate', {
   integrationPattern: sfn.IntegrationPattern.RUN_JOB,
   cluster,
   taskDefinition,
@@ -547,15 +513,15 @@ Corresponds to the [`runJobFlow`](https://docs.aws.amazon.com/emr/latest/APIRefe
 
 ```ts
 
-const clusterRole = new iam.Role(stack, 'ClusterRole', {
+const clusterRole = new iam.Role(this, 'ClusterRole', {
   assumedBy: new iam.ServicePrincipal('ec2.amazonaws.com'),
 });
 
-const serviceRole = new iam.Role(stack, 'ServiceRole', {
+const serviceRole = new iam.Role(this, 'ServiceRole', {
   assumedBy: new iam.ServicePrincipal('elasticmapreduce.amazonaws.com'),
 });
 
-const autoScalingRole = new iam.Role(stack, 'AutoScalingRole', {
+const autoScalingRole = new iam.Role(this, 'AutoScalingRole', {
   assumedBy: new iam.ServicePrincipal('elasticmapreduce.amazonaws.com'),
 });
 
@@ -568,16 +534,15 @@ autoScalingRole.assumeRolePolicy?.addStatements(
     actions: [
       'sts:AssumeRole',
     ],
-  });
+  }));
 )
 
-new tasks.EmrCreateCluster(stack, 'Create Cluster', {
+new tasks.EmrCreateCluster(this, 'Create Cluster', {
   instances: {},
   clusterRole,
   name: sfn.TaskInput.fromDataAt('$.ClusterName').value,
   serviceRole,
   autoScalingRole,
-  integrationPattern: sfn.ServiceIntegrationPattern.FIRE_AND_FORGET,
 });
 ```
 
@@ -589,7 +554,7 @@ terminated by user intervention, an API call, or a job-flow error.
 Corresponds to the [`setTerminationProtection`](https://docs.aws.amazon.com/step-functions/latest/dg/connect-emr.html) API in EMR.
 
 ```ts
-new tasks.EmrSetClusterTerminationProtection(stack, 'Task', {
+new tasks.EmrSetClusterTerminationProtection(this, 'Task', {
   clusterId: 'ClusterId',
   terminationProtected: false,
 });
@@ -601,7 +566,7 @@ Shuts down a cluster (job flow).
 Corresponds to the [`terminateJobFlows`](https://docs.aws.amazon.com/emr/latest/APIReference/API_TerminateJobFlows.html) API in EMR.
 
 ```ts
-new tasks.EmrTerminateCluster(stack, 'Task', {
+new tasks.EmrTerminateCluster(this, 'Task', {
   clusterId: 'ClusterId'
 });
 ```
@@ -612,7 +577,7 @@ Adds a new step to a running cluster.
 Corresponds to the [`addJobFlowSteps`](https://docs.aws.amazon.com/emr/latest/APIReference/API_AddJobFlowSteps.html) API in EMR.
 
 ```ts
-new tasks.EmrAddStep(stack, 'Task', {
+new tasks.EmrAddStep(this, 'Task', {
     clusterId: 'ClusterId',
     name: 'StepName',
     jar: 'Jar',
@@ -626,7 +591,7 @@ Cancels a pending step in a running cluster.
 Corresponds to the [`cancelSteps`](https://docs.aws.amazon.com/emr/latest/APIReference/API_CancelSteps.html) API in EMR.
 
 ```ts
-new tasks.EmrCancelStep(stack, 'Task', {
+new tasks.EmrCancelStep(this, 'Task', {
   clusterId: 'ClusterId',
   stepId: 'StepId',
 });
@@ -640,7 +605,7 @@ fleet with the specified InstanceFleetName.
 Corresponds to the [`modifyInstanceFleet`](https://docs.aws.amazon.com/emr/latest/APIReference/API_ModifyInstanceFleet.html) API in EMR.
 
 ```ts
-new sfn.EmrModifyInstanceFleetByName(stack, 'Task', {
+new tasks.EmrModifyInstanceFleetByName(this, 'Task', {
   clusterId: 'ClusterId',
   instanceFleetName: 'InstanceFleetName',
   targetOnDemandCapacity: 2,
@@ -655,7 +620,7 @@ Modifies the number of nodes and configuration settings of an instance group.
 Corresponds to the [`modifyInstanceGroups`](https://docs.aws.amazon.com/emr/latest/APIReference/API_ModifyInstanceGroups.html) API in EMR.
 
 ```ts
-new tasks.EmrModifyInstanceGroupByName(stack, 'Task', {
+new tasks.EmrModifyInstanceGroupByName(this, 'Task', {
   clusterId: 'ClusterId',
   instanceGroupName: sfn.JsonPath.stringAt('$.InstanceGroupName'),
   instanceGroup: {
@@ -671,11 +636,11 @@ Step Functions supports [AWS Glue](https://docs.aws.amazon.com/step-functions/la
 You can call the [`StartJobRun`](https://docs.aws.amazon.com/glue/latest/dg/aws-glue-api-jobs-runs.html#aws-glue-api-jobs-runs-StartJobRun) API from a `Task` state.
 
 ```ts
-new GlueStartJobRun(stack, 'Task', {
+new tasks.GlueStartJobRun(this, 'Task', {
   glueJobName: 'my-glue-job',
-  arguments: {
-    key: 'value',
-  },
+  arguments: sfn.TaskInput.fromObject({
+    key: 'value',  
+  }),
   timeout: cdk.Duration.minutes(30),
   notifyDelayAfter: cdk.Duration.minutes(5),
 });
@@ -688,8 +653,8 @@ Step Functions supports [AWS Glue DataBrew](https://docs.aws.amazon.com/step-fun
 You can call the [`StartJobRun`](https://docs.aws.amazon.com/databrew/latest/dg/API_StartJobRun.html) API from a `Task` state.
 
 ```ts
-new GlueDataBrewStartJobRun(stack, 'Task', {
-  Name: 'databrew-job',
+new tasks.GlueDataBrewStartJobRun(this, 'Task', {
+  name: 'databrew-job',
 });
 ```
 
@@ -704,24 +669,9 @@ as the input.
 The following snippet invokes a Lambda Function with the state input as the payload
 by referencing the `$` path.
 
-```ts
-import * as lambda from '@aws-cdk/aws-lambda';
-import * as sfn from '@aws-cdk/aws-stepfunctions';
-import * as tasks from '@aws-cdk/aws-stepfunctions-tasks';
-
-const myLambda = new lambda.Function(this, 'my sample lambda', {
-  code: Code.fromInline(`exports.handler = async () => {
-    return {
-      statusCode: '200',
-      body: 'hello, world!'
-    };
-  };`),
-  runtime: Runtime.NODEJS_12_X,
-  handler: 'index.handler',
-});
-
+```ts fixture=with-lambda
 new tasks.LambdaInvoke(this, 'Invoke with state input', {
-  lambdaFunction: myLambda,
+  lambdaFunction: fn,
 });
 ```
 
@@ -734,15 +684,15 @@ back.
 The following snippet invokes a Lambda Function by referencing the `$.Payload` path
 to reference the output of a Lambda executed before it.
 
-```ts
+```ts fixture=with-lambda
 new tasks.LambdaInvoke(this, 'Invoke with empty object as payload', {
-  lambdaFunction: myLambda,
+  lambdaFunction: fn,
   payload: sfn.TaskInput.fromObject({}),
 });
 
-// use the output of myLambda as input
+// use the output of fn as input
 new tasks.LambdaInvoke(this, 'Invoke with payload field in the state input', {
-  lambdaFunction: myOtherLambda,
+  lambdaFunction: fn,
   payload: sfn.TaskInput.fromDataAt('$.Payload'),
 });
 ```
@@ -750,10 +700,9 @@ new tasks.LambdaInvoke(this, 'Invoke with payload field in the state input', {
 The following snippet invokes a Lambda and sets the task output to only include
 the Lambda function response.
 
-```ts
+```ts fixture=with-lambda
 new tasks.LambdaInvoke(this, 'Invoke and set function response as task output', {
-  lambdaFunction: myLambda,
-  payload: sfn.TaskInput.fromDataAt('$'),
+  lambdaFunction: fn,
   outputPath: '$.Payload',
 });
 ```
@@ -763,11 +712,11 @@ the `payloadResponseOnly` property and specify the `resultPath`. This will put t
 Lambda function ARN directly in the "Resource" string, but it conflicts with the
 integrationPattern, invocationType, clientContext, and qualifier properties.
 
-```ts
+```ts fixture=with-lambda
 new tasks.LambdaInvoke(this, 'Invoke and combine function response with task input', {
-  lambdaFunction: myLambda,
+  lambdaFunction: fn,
   payloadResponseOnly: true,
-  resultPath: '$.myLambda',
+  resultPath: '$.fn',
 });
 ```
 
@@ -781,9 +730,9 @@ indicate that the task has completed and the state machine should resume executi
 The following snippet invokes a Lambda with the task token as part of the input
 to the Lambda.
 
-```ts
-new tasks.LambdaInvoke(stack, 'Invoke with callback', {
-  lambdaFunction: myLambda,
+```ts fixture=with-lambda
+new tasks.LambdaInvoke(this, 'Invoke with callback', {
+  lambdaFunction: fn,
   integrationPattern: sfn.IntegrationPattern.WAIT_FOR_TASK_TOKEN,
   payload: sfn.TaskInput.fromObject({
     token: sfn.JsonPath.taskToken,
@@ -798,7 +747,7 @@ Token](https://docs.aws.amazon.com/step-functions/latest/dg/connect-to-resource.
 
 AWS Lambda can occasionally experience transient service errors. In this case, invoking Lambda
 results in a 500 error, such as `ServiceException`, `AWSLambdaException`, or `SdkClientException`.
-As a best practive, the `LambdaInvoke` task will retry on those errors with an interval of 2 seconds,
+As a best practice, the `LambdaInvoke` task will retry on those errors with an interval of 2 seconds,
 a back-off rate of 2 and 6 maximum attempts. Set the `retryOnServiceExceptions` prop to `false` to
 disable this behavior.
 
@@ -811,9 +760,8 @@ Step Functions supports [AWS SageMaker](https://docs.aws.amazon.com/step-functio
 You can call the [`CreateTrainingJob`](https://docs.aws.amazon.com/sagemaker/latest/dg/API_CreateTrainingJob.html) API from a `Task` state.
 
 ```ts
-new sfn.SagemakerTrainTask(this, 'TrainSagemaker', {
+new tasks.SageMakerCreateTrainingJob(this, 'TrainSagemaker', {
   trainingJobName: sfn.JsonPath.stringAt('$.JobName'),
-  role,
   algorithmSpecification: {
     algorithmName: 'BlazingText',
     trainingInputMode: tasks.InputMode.FILE,
@@ -828,16 +776,16 @@ new sfn.SagemakerTrainTask(this, 'TrainSagemaker', {
     },
   }],
   outputDataConfig: {
-    s3OutputLocation: tasks.S3Location.fromBucket(s3.Bucket.fromBucketName(stack, 'Bucket', 'mybucket'), 'myoutputpath'),
+    s3OutputLocation: tasks.S3Location.fromBucket(s3.Bucket.fromBucketName(this, 'Bucket', 'mybucket'), 'myoutputpath'),
   },
   resourceConfig: {
     instanceCount: 1,
     instanceType: ec2.InstanceType.of(ec2.InstanceClass.P3, ec2.InstanceSize.XLARGE2),
     volumeSize: cdk.Size.gibibytes(50),
-  },
+  }, // optional: default is 1 instance of EC2 `M4.XLarge` with `10GB` volume
   stoppingCondition: {
-    maxRuntime: cdk.Duration.hours(1),
-  },
+    maxRuntime: cdk.Duration.hours(2),
+  }, // optional: default is 1 hour
 });
 ```
 
@@ -846,19 +794,18 @@ new sfn.SagemakerTrainTask(this, 'TrainSagemaker', {
 You can call the [`CreateTransformJob`](https://docs.aws.amazon.com/sagemaker/latest/dg/API_CreateTransformJob.html) API from a `Task` state.
 
 ```ts
-new sfn.SagemakerTransformTask(this, 'Batch Inference', {
+new tasks.SageMakerCreateTransformJob(this, 'Batch Inference', {
   transformJobName: 'MyTransformJob',
   modelName: 'MyModelName',
   modelClientOptions: {
-    invocationMaxRetries: 3,  // default is 0
-    invocationTimeout: cdk.Duration.minutes(5),  // default is 60 seconds
-  }
-  role,
+    invocationsMaxRetries: 3,  // default is 0
+    invocationsTimeout: cdk.Duration.minutes(5),  // default is 60 seconds
+  },
   transformInput: {
     transformDataSource: {
       s3DataSource: {
         s3Uri: 's3://inputbucket/train',
-        s3DataType: S3DataType.S3Prefix,
+        s3DataType: tasks.S3DataType.S3_PREFIX,
       }
     }
   },
@@ -867,7 +814,7 @@ new sfn.SagemakerTransformTask(this, 'Batch Inference', {
   },
   transformResources: {
     instanceCount: 1,
-    instanceType: ec2.InstanceType.of(ec2.InstanceClass.M4, ec2.InstanceSize.XLarge),
+    instanceType: ec2.InstanceType.of(ec2.InstanceClass.M4, ec2.InstanceSize.XLARGE),
   }
 });
 
@@ -878,7 +825,7 @@ new sfn.SagemakerTransformTask(this, 'Batch Inference', {
 You can call the [`CreateEndpoint`](https://docs.aws.amazon.com/sagemaker/latest/APIReference/API_CreateEndpoint.html) API from a `Task` state.
 
 ```ts
-new sfn.SageMakerCreateEndpoint(this, 'SagemakerEndpoint', {
+new tasks.SageMakerCreateEndpoint(this, 'SagemakerEndpoint', {
   endpointName: sfn.JsonPath.stringAt('$.EndpointName'),
   endpointConfigName: sfn.JsonPath.stringAt('$.EndpointConfigName'),
 });
@@ -889,7 +836,7 @@ new sfn.SageMakerCreateEndpoint(this, 'SagemakerEndpoint', {
 You can call the [`CreateEndpointConfig`](https://docs.aws.amazon.com/sagemaker/latest/APIReference/API_CreateEndpointConfig.html) API from a `Task` state.
 
 ```ts
-new sfn.SageMakerCreateEndpointConfig(this, 'SagemakerEndpointConfig', {
+new tasks.SageMakerCreateEndpointConfig(this, 'SagemakerEndpointConfig', {
   endpointConfigName: 'MyEndpointConfig',
   productionVariants: [{
   initialInstanceCount: 2,
@@ -905,7 +852,7 @@ new sfn.SageMakerCreateEndpointConfig(this, 'SagemakerEndpointConfig', {
 You can call the [`CreateModel`](https://docs.aws.amazon.com/sagemaker/latest/APIReference/API_CreateModel.html) API from a `Task` state.
 
 ```ts
-new sfn.SageMakerCreateModel(this, 'Sagemaker', {
+new tasks.SageMakerCreateModel(this, 'Sagemaker', {
   modelName: 'MyModel',
   primaryContainer: new tasks.ContainerDefinition({
    image: tasks.DockerImage.fromJsonExpression(sfn.JsonPath.stringAt('$.Model.imageName')),
@@ -920,7 +867,7 @@ new sfn.SageMakerCreateModel(this, 'Sagemaker', {
 You can call the [`UpdateEndpoint`](https://docs.aws.amazon.com/sagemaker/latest/APIReference/API_UpdateEndpoint.html) API from a `Task` state.
 
 ```ts
-new sfn.SageMakerUpdateEndpoint(this, 'SagemakerEndpoint', {
+new tasks.SageMakerUpdateEndpoint(this, 'SagemakerEndpoint', {
     endpointName: sfn.JsonPath.stringAt('$.Endpoint.Name'),
     endpointConfigName: sfn.JsonPath.stringAt('$.Endpoint.EndpointConfig'),
   });
@@ -933,12 +880,6 @@ Step Functions supports [Amazon SNS](https://docs.aws.amazon.com/step-functions/
 You can call the [`Publish`](https://docs.aws.amazon.com/sns/latest/api/API_Publish.html) API from a `Task` state to publish to an SNS topic.
 
 ```ts
-import * as sns from '@aws-cdk/aws-sns';
-import * as sfn from '@aws-cdk/aws-stepfunctions';
-import * as tasks from '@aws-cdk/aws-stepfunctions-tasks';
-
-// ...
-
 const topic = new sns.Topic(this, 'Topic');
 
 // Use a field from the execution data as message.
@@ -969,12 +910,12 @@ AWS Step Functions supports it's own [`StartExecution`](https://docs.aws.amazon.
 
 ```ts
 // Define a state machine with one Pass state
-const child = new sfn.StateMachine(stack, 'ChildStateMachine', {
-    definition: sfn.Chain.start(new sfn.Pass(stack, 'PassState')),
+const child = new sfn.StateMachine(this, 'ChildStateMachine', {
+    definition: sfn.Chain.start(new sfn.Pass(this, 'PassState')),
 });
 
 // Include the state machine in a Task state with callback pattern
-const task = new StepFunctionsStartExecution(stack, 'ChildTask', {
+const task = new tasks.StepFunctionsStartExecution(this, 'ChildTask', {
   stateMachine: child,
   integrationPattern: sfn.IntegrationPattern.WAIT_FOR_TASK_TOKEN,
   input: sfn.TaskInput.fromObject({
@@ -985,7 +926,7 @@ const task = new StepFunctionsStartExecution(stack, 'ChildTask', {
 });
 
 // Define a second state machine with the Task state above
-new sfn.StateMachine(stack, 'ParentStateMachine', {
+new sfn.StateMachine(this, 'ParentStateMachine', {
   definition: task
 });
 ```
@@ -1025,12 +966,6 @@ You can call the [`SendMessage`](https://docs.aws.amazon.com/AWSSimpleQueueServi
 to send a message to an SQS queue.
 
 ```ts
-import * as sfn from '@aws-cdk/aws-stepfunctions';
-import * as tasks from '@aws-cdk/aws-stepfunctions-tasks';
-import * as sqs from '@aws-cdk/aws-sqs';
-
-// ...
-
 const queue = new sqs.Queue(this, 'Queue');
 
 // Use a field from the execution data as message.
diff --git a/packages/@aws-cdk/aws-stepfunctions-tasks/rosetta/default.ts-fixture b/packages/@aws-cdk/aws-stepfunctions-tasks/rosetta/default.ts-fixture
new file mode 100644
index 0000000000000..baa780d682203
--- /dev/null
+++ b/packages/@aws-cdk/aws-stepfunctions-tasks/rosetta/default.ts-fixture
@@ -0,0 +1,19 @@
+// Fixture with packages imported, but nothing else
+import * as cdk from '@aws-cdk/core';
+import { Construct } from 'constructs';
+import * as ec2 from '@aws-cdk/aws-ec2';
+import * as iam from '@aws-cdk/aws-iam';
+import * as lambda from '@aws-cdk/aws-lambda';
+import * as s3 from '@aws-cdk/aws-s3';
+import * as sfn from '@aws-cdk/aws-stepfunctions';
+import * as sns from '@aws-cdk/aws-sns';
+import * as sqs from '@aws-cdk/aws-sqs';
+import * as tasks from '@aws-cdk/aws-stepfunctions-tasks';
+
+class Fixture extends cdk.Stack {
+  constructor(scope: Construct, id: string) {
+    super(scope, id);
+
+    /// here
+  }
+}
diff --git a/packages/@aws-cdk/aws-stepfunctions-tasks/rosetta/with-batch-job.ts-fixture b/packages/@aws-cdk/aws-stepfunctions-tasks/rosetta/with-batch-job.ts-fixture
new file mode 100644
index 0000000000000..47672ba140841
--- /dev/null
+++ b/packages/@aws-cdk/aws-stepfunctions-tasks/rosetta/with-batch-job.ts-fixture
@@ -0,0 +1,38 @@
+// Fixture with packages imported, but nothing else
+import { Stack } from '@aws-cdk/core';
+import { Construct } from 'constructs';
+import * as sfn from '@aws-cdk/aws-stepfunctions';
+import * as tasks from '@aws-cdk/aws-stepfunctions-tasks';
+import * as batch from '@aws-cdk/aws-batch';
+import * as ec2 from '@aws-cdk/aws-ec2';
+import * as ecs from '@aws-cdk/aws-ecs';
+import * as path from 'path';
+
+class Fixture extends Stack {
+  constructor(scope: Construct, id: string) {
+    super(scope, id);
+
+    const vpc = ec2.Vpc.fromLookup(this, 'Vpc', {
+      isDefault: true,
+    });
+
+    const batchQueue = new batch.JobQueue(this, 'JobQueue', {
+      computeEnvironments: [
+        {
+          order: 1,
+          computeEnvironment: new batch.ComputeEnvironment(this, 'ComputeEnv', {
+            computeResources: { vpc },
+          }),
+        },
+      ],
+    });
+
+    const batchJobDefinition = new batch.JobDefinition(this, 'JobDefinition', {
+      container: {
+      image: ecs.ContainerImage.fromAsset(path.resolve(__dirname, 'batchjob-image')),
+      },
+    });
+
+    /// here
+  }
+}
diff --git a/packages/@aws-cdk/aws-stepfunctions-tasks/rosetta/with-ddb-table.ts-fixture b/packages/@aws-cdk/aws-stepfunctions-tasks/rosetta/with-ddb-table.ts-fixture
new file mode 100644
index 0000000000000..f0196c7e99289
--- /dev/null
+++ b/packages/@aws-cdk/aws-stepfunctions-tasks/rosetta/with-ddb-table.ts-fixture
@@ -0,0 +1,23 @@
+// Fixture with packages imported, but nothing else
+import { RemovalPolicy, Stack } from '@aws-cdk/core';
+import { Construct } from 'constructs';
+import * as sfn from '@aws-cdk/aws-stepfunctions';
+import * as tasks from '@aws-cdk/aws-stepfunctions-tasks';
+import * as ddb from '@aws-cdk/aws-dynamodb';
+
+class Fixture extends Stack {
+  constructor(scope: Construct, id: string) {
+    super(scope, id);
+
+    const myTable = new ddb.Table(this, 'Messages', {
+      tableName: 'my-table',
+      partitionKey: {
+        name: 'MessageId',
+        type: ddb.AttributeType.STRING,
+      },
+      removalPolicy: RemovalPolicy.DESTROY,
+    });
+
+    /// here
+  }
+}
diff --git a/packages/@aws-cdk/aws-stepfunctions-tasks/rosetta/with-lambda.ts-fixture b/packages/@aws-cdk/aws-stepfunctions-tasks/rosetta/with-lambda.ts-fixture
new file mode 100644
index 0000000000000..8cd4af7915186
--- /dev/null
+++ b/packages/@aws-cdk/aws-stepfunctions-tasks/rosetta/with-lambda.ts-fixture
@@ -0,0 +1,22 @@
+// Fixture with packages imported, but nothing else
+import { Stack } from '@aws-cdk/core';
+import { Construct } from 'constructs';
+import * as sfn from '@aws-cdk/aws-stepfunctions';
+import * as tasks from '@aws-cdk/aws-stepfunctions-tasks';
+import * as lambda from '@aws-cdk/aws-lambda';
+
+class Fixture extends Stack {
+  constructor(scope: Construct, id: string) {
+    super(scope, id);
+
+    const fn = new lambda.Function(this, 'lambdaFunction', {
+      code: lambda.Code.fromInline(`exports.handler = async () => {
+        return { "hello world"};
+      `),
+      runtime: lambda.Runtime.NODEJS_12_X,
+      handler: 'index.handler',
+    });
+
+    /// here
+  }
+}

From 6aaf42896bfa5dca22ac953064400ec01a7bbd57 Mon Sep 17 00:00:00 2001
From: Shiv Lakshminarayan <shivlaks@amazon.com>
Date: Wed, 3 Mar 2021 15:35:19 -0800
Subject: [PATCH 2/2] PR fixup

---
 .../aws-stepfunctions-tasks/README.md         | 26 +++++++++----------
 .../rosetta/default.ts-fixture                | 18 +++++++++++++
 .../rosetta/with-ddb-table.ts-fixture         | 23 ----------------
 .../rosetta/with-lambda.ts-fixture            | 22 ----------------
 4 files changed, 31 insertions(+), 58 deletions(-)
 delete mode 100644 packages/@aws-cdk/aws-stepfunctions-tasks/rosetta/with-ddb-table.ts-fixture
 delete mode 100644 packages/@aws-cdk/aws-stepfunctions-tasks/rosetta/with-lambda.ts-fixture

diff --git a/packages/@aws-cdk/aws-stepfunctions-tasks/README.md b/packages/@aws-cdk/aws-stepfunctions-tasks/README.md
index 9fee9cb2618b5..114ee702546a4 100644
--- a/packages/@aws-cdk/aws-stepfunctions-tasks/README.md
+++ b/packages/@aws-cdk/aws-stepfunctions-tasks/README.md
@@ -99,7 +99,7 @@ of `$` will be used.
 The following example provides the field named `input` as the input to the `Task`
 state that runs a Lambda function.
 
-```ts fixture=with-lambda
+```ts
 const submitJob = new tasks.LambdaInvoke(this, 'Invoke Handler', {
   lambdaFunction: fn,
   inputPath: '$.input'
@@ -119,7 +119,7 @@ as well as other metadata.
 
 The following example assigns the output from the Task to a field named `result`
 
-```ts fixture=with-lambda
+```ts
 const submitJob = new tasks.LambdaInvoke(this, 'Invoke Handler', {
   lambdaFunction: fn,
   outputPath: '$.Payload.result'
@@ -137,7 +137,7 @@ value of `$` will be used.
 The following example adds the item from calling DynamoDB's `getItem` API to the state
 input and passes it to the next state.
 
-```ts fixture=with-ddb-table
+```ts
 new tasks.DynamoPutItem(this, 'PutItem', {
   item: {
     MessageId: tasks.DynamoAttributeValue.fromString('message-id')
@@ -162,7 +162,7 @@ using methods such as `JsonPath.stringAt()`.
 The following example provides the field named `input` as the input to the Lambda function
 and invokes it asynchronously.
 
-```ts fixture=with-lambda
+```ts
 const submitJob = new tasks.LambdaInvoke(this, 'Invoke Handler', {
   lambdaFunction: fn,
   payload: sfn.TaskInput.fromDataAt('$.input'),
@@ -334,7 +334,7 @@ Read more about calling DynamoDB APIs [here](https://docs.aws.amazon.com/step-fu
 
 The [GetItem](https://docs.aws.amazon.com/amazondynamodb/latest/APIReference/API_GetItem.html) operation returns a set of attributes for the item with the given primary key.
 
-```ts fixture=with-ddb-table
+```ts
 new tasks.DynamoGetItem(this, 'Get Item', {
   key: { messageId: tasks.DynamoAttributeValue.fromString('message-007') },
   table: myTable,
@@ -345,7 +345,7 @@ new tasks.DynamoGetItem(this, 'Get Item', {
 
 The [PutItem](https://docs.aws.amazon.com/amazondynamodb/latest/APIReference/API_PutItem.html) operation creates a new item, or replaces an old item with a new item.
 
-```ts fixture=with-ddb-table
+```ts
 new tasks.DynamoPutItem(this, 'PutItem', {
   item: {
     MessageId: tasks.DynamoAttributeValue.fromString('message-007'),
@@ -360,7 +360,7 @@ new tasks.DynamoPutItem(this, 'PutItem', {
 
 The [DeleteItem](https://docs.aws.amazon.com/amazondynamodb/latest/APIReference/API_DeleteItem.html) operation deletes a single item in a table by primary key.
 
-```ts fixture=with-ddb-table
+```ts
 new tasks.DynamoDeleteItem(this, 'DeleteItem', {
   key: { MessageId: tasks.DynamoAttributeValue.fromString('message-007') },
   table: myTable,
@@ -373,7 +373,7 @@ new tasks.DynamoDeleteItem(this, 'DeleteItem', {
 The [UpdateItem](https://docs.aws.amazon.com/amazondynamodb/latest/APIReference/API_UpdateItem.html) operation edits an existing item's attributes, or adds a new item
 to the table if it does not already exist.
 
-```ts fixture=with-ddb-table
+```ts
 new tasks.DynamoUpdateItem(this, 'UpdateItem', {
   key: {
     MessageId: tasks.DynamoAttributeValue.fromString('message-007')
@@ -669,7 +669,7 @@ as the input.
 The following snippet invokes a Lambda Function with the state input as the payload
 by referencing the `$` path.
 
-```ts fixture=with-lambda
+```ts
 new tasks.LambdaInvoke(this, 'Invoke with state input', {
   lambdaFunction: fn,
 });
@@ -684,7 +684,7 @@ back.
 The following snippet invokes a Lambda Function by referencing the `$.Payload` path
 to reference the output of a Lambda executed before it.
 
-```ts fixture=with-lambda
+```ts
 new tasks.LambdaInvoke(this, 'Invoke with empty object as payload', {
   lambdaFunction: fn,
   payload: sfn.TaskInput.fromObject({}),
@@ -700,7 +700,7 @@ new tasks.LambdaInvoke(this, 'Invoke with payload field in the state input', {
 The following snippet invokes a Lambda and sets the task output to only include
 the Lambda function response.
 
-```ts fixture=with-lambda
+```ts
 new tasks.LambdaInvoke(this, 'Invoke and set function response as task output', {
   lambdaFunction: fn,
   outputPath: '$.Payload',
@@ -712,7 +712,7 @@ the `payloadResponseOnly` property and specify the `resultPath`. This will put t
 Lambda function ARN directly in the "Resource" string, but it conflicts with the
 integrationPattern, invocationType, clientContext, and qualifier properties.
 
-```ts fixture=with-lambda
+```ts
 new tasks.LambdaInvoke(this, 'Invoke and combine function response with task input', {
   lambdaFunction: fn,
   payloadResponseOnly: true,
@@ -730,7 +730,7 @@ indicate that the task has completed and the state machine should resume executi
 The following snippet invokes a Lambda with the task token as part of the input
 to the Lambda.
 
-```ts fixture=with-lambda
+```ts
 new tasks.LambdaInvoke(this, 'Invoke with callback', {
   lambdaFunction: fn,
   integrationPattern: sfn.IntegrationPattern.WAIT_FOR_TASK_TOKEN,
diff --git a/packages/@aws-cdk/aws-stepfunctions-tasks/rosetta/default.ts-fixture b/packages/@aws-cdk/aws-stepfunctions-tasks/rosetta/default.ts-fixture
index baa780d682203..11558a599e5f4 100644
--- a/packages/@aws-cdk/aws-stepfunctions-tasks/rosetta/default.ts-fixture
+++ b/packages/@aws-cdk/aws-stepfunctions-tasks/rosetta/default.ts-fixture
@@ -1,6 +1,7 @@
 // Fixture with packages imported, but nothing else
 import * as cdk from '@aws-cdk/core';
 import { Construct } from 'constructs';
+import * as ddb from '@aws-cdk/aws-dynamodb';
 import * as ec2 from '@aws-cdk/aws-ec2';
 import * as iam from '@aws-cdk/aws-iam';
 import * as lambda from '@aws-cdk/aws-lambda';
@@ -14,6 +15,23 @@ class Fixture extends cdk.Stack {
   constructor(scope: Construct, id: string) {
     super(scope, id);
 
+    const fn = new lambda.Function(this, 'lambdaFunction', {
+      code: lambda.Code.fromInline(`exports.handler = async () => {
+        return { "hello world"};
+      `),
+      runtime: lambda.Runtime.NODEJS_12_X,
+      handler: 'index.handler',
+    });
+
+    const myTable = new ddb.Table(this, 'Messages', {
+      tableName: 'my-table',
+      partitionKey: {
+        name: 'MessageId',
+        type: ddb.AttributeType.STRING,
+      },
+      removalPolicy: cdk.RemovalPolicy.DESTROY,
+    });
+
     /// here
   }
 }
diff --git a/packages/@aws-cdk/aws-stepfunctions-tasks/rosetta/with-ddb-table.ts-fixture b/packages/@aws-cdk/aws-stepfunctions-tasks/rosetta/with-ddb-table.ts-fixture
deleted file mode 100644
index f0196c7e99289..0000000000000
--- a/packages/@aws-cdk/aws-stepfunctions-tasks/rosetta/with-ddb-table.ts-fixture
+++ /dev/null
@@ -1,23 +0,0 @@
-// Fixture with packages imported, but nothing else
-import { RemovalPolicy, Stack } from '@aws-cdk/core';
-import { Construct } from 'constructs';
-import * as sfn from '@aws-cdk/aws-stepfunctions';
-import * as tasks from '@aws-cdk/aws-stepfunctions-tasks';
-import * as ddb from '@aws-cdk/aws-dynamodb';
-
-class Fixture extends Stack {
-  constructor(scope: Construct, id: string) {
-    super(scope, id);
-
-    const myTable = new ddb.Table(this, 'Messages', {
-      tableName: 'my-table',
-      partitionKey: {
-        name: 'MessageId',
-        type: ddb.AttributeType.STRING,
-      },
-      removalPolicy: RemovalPolicy.DESTROY,
-    });
-
-    /// here
-  }
-}
diff --git a/packages/@aws-cdk/aws-stepfunctions-tasks/rosetta/with-lambda.ts-fixture b/packages/@aws-cdk/aws-stepfunctions-tasks/rosetta/with-lambda.ts-fixture
deleted file mode 100644
index 8cd4af7915186..0000000000000
--- a/packages/@aws-cdk/aws-stepfunctions-tasks/rosetta/with-lambda.ts-fixture
+++ /dev/null
@@ -1,22 +0,0 @@
-// Fixture with packages imported, but nothing else
-import { Stack } from '@aws-cdk/core';
-import { Construct } from 'constructs';
-import * as sfn from '@aws-cdk/aws-stepfunctions';
-import * as tasks from '@aws-cdk/aws-stepfunctions-tasks';
-import * as lambda from '@aws-cdk/aws-lambda';
-
-class Fixture extends Stack {
-  constructor(scope: Construct, id: string) {
-    super(scope, id);
-
-    const fn = new lambda.Function(this, 'lambdaFunction', {
-      code: lambda.Code.fromInline(`exports.handler = async () => {
-        return { "hello world"};
-      `),
-      runtime: lambda.Runtime.NODEJS_12_X,
-      handler: 'index.handler',
-    });
-
-    /// here
-  }
-}