Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -13,7 +13,7 @@ class SfnRestApiWithoutDefaultMethodResponsesStack extends cdk.Stack {
});

const stateMachine = new sfn.StateMachine(this, 'StateMachine', {
definition: passTask,
definitionBody: sfn.DefinitionBody.fromChainable(passTask),
stateMachineType: sfn.StateMachineType.EXPRESS,
});

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -20,7 +20,7 @@ class StepFunctionsRestApiDeploymentStack extends cdk.Stack {
});

const stateMachine = new sfn.StateMachine(this, 'StateMachine', {
definition: passTask,
definitionBody: sfn.DefinitionBody.fromChainable(passTask),
stateMachineType: sfn.StateMachineType.EXPRESS,
});

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -8,10 +8,10 @@ const app = new App();
const stack = new Stack(app, 'stepfunctions-integration');

const stateMachine = new sfn.StateMachine(stack, 'RouteStateMachine', {
definition: new sfn.Pass(stack, 'Pass1'),
definitionBody: sfn.DefinitionBody.fromChainable(new sfn.Pass(stack, 'Pass1')),
});
const expressStateMachine = new sfn.StateMachine(stack, 'ExpressStateMachine', {
definition: new sfn.Pass(stack, 'Pass2'),
definitionBody: sfn.DefinitionBody.fromChainable(new sfn.Pass(stack, 'Pass2')),
stateMachineType: sfn.StateMachineType.EXPRESS,
});

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -25,9 +25,9 @@ class StepFunctionStack extends Stack {

// Create a simple Step Function
this.stateMachine = new sfn.StateMachine(this, 'CrossAccountStateMachine', {
definition: new sfn.Pass(this, 'PassState', {
definitionBody: sfn.DefinitionBody.fromChainable(new sfn.Pass(this, 'PassState', {
result: sfn.Result.fromObject({ message: 'Hello from cross-account Step Function!' }),
}),
})),
stateMachineName: 'CrossAccountStateMachine',
});

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -17,7 +17,7 @@ const sourceOutput = new codepipeline.Artifact();

const startState = new stepfunctions.Pass(stack, 'StartState');
const simpleStateMachine = new stepfunctions.StateMachine(stack, 'SimpleStateMachine', {
definition: startState,
definitionBody: stepfunctions.DefinitionBody.fromChainable(startState),
});

const pipeline = new codepipeline.Pipeline(stack, 'MyPipeline', {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -52,7 +52,7 @@ const callEndpointJob = new CallApiGatewayRestApiEndpoint(sfnStack, 'Call APIGW'
const chain = sfn.Chain.start(callEndpointJob);

const sm = new sfn.StateMachine(sfnStack, 'StateMachine', {
definition: chain,
definitionBody: sfn.DefinitionBody.fromChainable(chain),
timeout: cdk.Duration.seconds(30),
});

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -40,7 +40,7 @@ const callEndpointJob = new CallApiGatewayRestApiEndpoint(stack, 'Call APIGW', {
const chain = sfn.Chain.start(callEndpointJob);

const sm = new sfn.StateMachine(stack, 'StateMachine', {
definition: chain,
definitionBody: sfn.DefinitionBody.fromChainable(chain),
timeout: cdk.Duration.seconds(30),
});

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -30,7 +30,7 @@ const getQueryExecutionJob = new AthenaGetQueryExecution(stack, 'Get Query Execu
const chain = sfn.Chain.start(startQueryExecutionJob).next(getQueryExecutionJob);

const sm = new sfn.StateMachine(stack, 'StateMachine', {
definition: chain,
definitionBody: sfn.DefinitionBody.fromChainable(chain),
timeout: cdk.Duration.seconds(30),
});

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -39,7 +39,7 @@ const chain = sfn.Chain
.next(getQueryResultsJob);

const sm = new sfn.StateMachine(stack, 'StateMachine', {
definition: chain,
definitionBody: sfn.DefinitionBody.fromChainable(chain),
timeout: cdk.Duration.seconds(30),
});

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -31,7 +31,7 @@ const startQueryExecutionJob = new AthenaStartQueryExecution(stack, 'Start Athen
const chain = sfn.Chain.start(startQueryExecutionJob);

const sm = new sfn.StateMachine(stack, 'StateMachine', {
definition: chain,
definitionBody: sfn.DefinitionBody.fromChainable(chain),
timeout: cdk.Duration.seconds(30),
});

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -32,7 +32,7 @@ const stopQueryExecutionJob = new AthenaStopQueryExecution(stack, 'Stop Query Ex
const chain = sfn.Chain.start(startQueryExecutionJob).next(stopQueryExecutionJob);

const sm = new sfn.StateMachine(stack, 'StateMachine', {
definition: chain,
definitionBody: sfn.DefinitionBody.fromChainable(chain),
timeout: cdk.Duration.seconds(30),
});

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -23,7 +23,7 @@ const task = new CallAwsService(stack, 'TagEfsAccessPoint', {
});

new sfn.StateMachine(stack, 'StateMachine', {
definition: task,
definitionBody: sfn.DefinitionBody.fromChainable(task),
});

// THEN
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -14,7 +14,7 @@ const task = new CallAwsService(stack, 'DescribeELBV2TargetGroups', {
});

const stateMachine = new sfn.StateMachine(stack, 'StateMachine', {
definition: task,
definitionBody: sfn.DefinitionBody.fromChainable(task),
});

// THEN
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -58,7 +58,7 @@ class TestStack extends cdk.Stack {
});

this.stateMachine = new sfn.StateMachine(this, 'StateMachine', {
definition: putObject.next(getObject).next(deleteObject),
definitionBody: sfn.DefinitionBody.fromChainable(putObject.next(getObject).next(deleteObject)),
});

new cdk.CfnOutput(this, 'StateMachineArn', {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -20,7 +20,7 @@ const task = new CallAwsService(stack, 'SendTaskSuccess', {
});

const stateMachine = new sfn.StateMachine(stack, 'StateMachine', {
definition: task,
definitionBody: sfn.DefinitionBody.fromChainable(task),
});

// THEN
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -14,7 +14,7 @@ const task = new CallAwsService(stack, 'ListMediaPackageVoDPackagingGroups', {
});

const stateMachine = new sfn.StateMachine(stack, 'StateMachine', {
definition: task,
definitionBody: sfn.DefinitionBody.fromChainable(task),
});

// THEN
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -14,7 +14,7 @@ const task = new CallAwsService(stack, 'ListMWAAEnvironments', {
});

const stateMachine = new sfn.StateMachine(stack, 'StateMachine', {
definition: task,
definitionBody: sfn.DefinitionBody.fromChainable(task),
});

// THEN
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -17,18 +17,18 @@ const task = new CallAwsService(stack, 'SendTaskSuccess', {
});

const childStateMachine = new sfn.StateMachine(stack, 'ChildStateMachine', {
definition: task,
definitionBody: sfn.DefinitionBody.fromChainable(task),
});

const stateMachine = new sfn.StateMachine(stack, 'ParentStateMachine', {
definition: new StepFunctionsStartExecution(stack, 'StepFunctionsStartExecution', {
definitionBody: sfn.DefinitionBody.fromChainable(new StepFunctionsStartExecution(stack, 'StepFunctionsStartExecution', {
stateMachine: childStateMachine,
integrationPattern: sfn.IntegrationPattern.WAIT_FOR_TASK_TOKEN,
input: sfn.TaskInput.fromObject({
output: sfn.JsonPath.entirePayload,
taskToken: sfn.JsonPath.taskToken,
}),
}),
})),
});

// THEN
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -51,7 +51,7 @@ class TestStack extends cdk.Stack {
});

const stateMachine = new sfn.StateMachine(this, 'StateMachine', {
definition: putObject.next(getObject).next(deleteObject),
definitionBody: sfn.DefinitionBody.fromChainable(putObject.next(getObject).next(deleteObject)),
});

new cdk.CfnOutput(this, 'StateMachineArn', {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -36,28 +36,26 @@ class RunBatchStack extends cdk.Stack {
memory: cdk.Size.mebibytes(2048),
}),
});
const submitJob = new sfn.Task(this, 'Submit Job', {
task: new tasks.RunBatchJob({
jobDefinitionArn: batchJobDefinition.jobDefinitionArn,
jobName: 'MyJob',
jobQueueArn: batchQueue.jobQueueArn,
containerOverrides: {
environment: { key: 'value' },
memory: 256,
vcpus: 1,
},
payload: {
foo: sfn.JsonPath.stringAt('$.bar'),
},
attempts: 3,
timeout: cdk.Duration.seconds(60),
const submitJob = new tasks.BatchSubmitJob(this, 'Submit Job', {
jobDefinitionArn: batchJobDefinition.jobDefinitionArn,
jobName: 'MyJob',
jobQueueArn: batchQueue.jobQueueArn,
containerOverrides: {
environment: { key: 'value' },
memory: cdk.Size.mebibytes(256),
vcpus: 1,
},
payload: sfn.TaskInput.fromObject({
foo: sfn.JsonPath.stringAt('$.bar'),
}),
attempts: 3,
taskTimeout: sfn.Timeout.duration(cdk.Duration.seconds(60)),
});
const definition = new sfn.Pass(this, 'Start', {
result: sfn.Result.fromObject({ bar: 'SomeValue' }),
}).next(submitJob);
const stateMachine = new sfn.StateMachine(this, 'StateMachine', {
definition,
definitionBody: sfn.DefinitionBody.fromChainable(definition),
});
new cdk.CfnOutput(this, 'JobQueueArn', {
value: batchQueue.jobQueueArn,
Expand Down

This file was deleted.

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

Loading
Loading