@@ -25,7 +25,7 @@ data "aws_iam_policy_document" "sfn_permissions" {
2525 actions = [" lambda:InvokeFunction" ]
2626 resources = [
2727 module . migration-dynamodb-segment-lambda . lambda_arn ,
28- # module.dynamodb_migration_lambda .lambda_arn
28+ module . migration-dynamodb-lambda . lambda_arn
2929 ]
3030 }
3131
@@ -152,31 +152,26 @@ resource "aws_sfn_state_machine" "migration_dynamodb" {
152152 Mode = " DISTRIBUTED" ,
153153 ExecutionType = " STANDARD"
154154 },
155- StartAt = " Placeholder " ,
155+ StartAt = " Run DynamoDB Migration " ,
156156 States = {
157- " Placeholder" = {
158- Type = " Pass" ,
159- Comment = " TODO: Replace with Run DynamoDB Migration when module.dynamodb_migration_lambda exists" ,
160- End = true
157+ " Run DynamoDB Migration" = {
158+ Type = " Task" ,
159+ Resource = " arn:aws:states:::lambda:invoke" ,
160+ Parameters = {
161+ FunctionName = module.migration- dynamodb- lambda.lambda_arn,
162+ " Payload" = {
163+ " segment.$" = " $.segment" ,
164+ " totalSegments.$" = " $.totalSegments" ,
165+ " tableArn.$" = " $.tableArn" ,
166+ " migrationScript.$" = " $.migrationScript" ,
167+ " run_migration.$" = " $.run_migration" ,
168+ " execution_Id.$" = " $.execution_Id"
169+ }
170+ },
171+ ResultSelector = { " migrationResult.$" = " $.Payload" },
172+ ResultPath = " $.MigrationResult" ,
173+ End = true
161174 }
162- # "Run DynamoDB Migration" = {
163- # Type = "Task",
164- # Resource = "arn:aws:states:::lambda:invoke",
165- # Parameters = {
166- # FunctionName = module.dynamodb_migration_lambda.lambda_arn,
167- # "Payload" = {
168- # "segment.$" = "$.segment",
169- # "totalSegments.$" = "$.totalSegments",
170- # "tableArn.$" = "$.tableArn",
171- # "migrationScript.$" = "$.migrationScript",
172- # "run_migration.$" = "$.run_migration",
173- # "execution_Id.$" = "$.execution_Id"
174- # }
175- # },
176- # ResultSelector = { "migrationResult.$" = "$.Payload" },
177- # ResultPath = "$.MigrationResult",
178- # End = true
179- # }
180175 }
181176 },
182177 End = true
0 commit comments