// The code below shows an example of how to instantiate this type.
// The values are placeholders you should change.
import * as stepfunctions from '@aws-cdk/aws-stepfunctions';
import * as stepfunctions_tasks from '@aws-cdk/aws-stepfunctions-tasks';
import * as cdk from '@aws-cdk/core';
const runGlueJobTask = new stepfunctions_tasks.RunGlueJobTask('glueJobName', /* all optional props */ {
arguments: {
argumentsKey: 'arguments',
},
integrationPattern: stepfunctions.ServiceIntegrationPattern.FIRE_AND_FORGET,
notifyDelayAfter: cdk.Duration.minutes(30),
securityConfiguration: 'securityConfiguration',
timeout: cdk.Duration.minutes(30),
});
// The code below shows an example of how to instantiate this type.
// The values are placeholders you should change.
import * as ec2 from '@aws-cdk/aws-ec2';
import * as stepfunctions from '@aws-cdk/aws-stepfunctions';
import * as stepfunctions_tasks from '@aws-cdk/aws-stepfunctions-tasks';
import * as cdk from '@aws-cdk/core';
declare const instanceType: ec2.InstanceType;
declare const payload: any;
const runBatchJob = new stepfunctions_tasks.RunBatchJob({
jobDefinitionArn: 'jobDefinitionArn',
jobName: 'jobName',
jobQueueArn: 'jobQueueArn',
// the properties below are optional
arraySize: 123,
attempts: 123,
containerOverrides: {
command: ['command'],
environment: {
environmentKey: 'environment',
},
gpuCount: 123,
instanceType: instanceType,
memory: 123,
vcpus: 123,
},
dependsOn: [{
jobId: 'jobId',
type: 'type',
}],
integrationPattern: stepfunctions.ServiceIntegrationPattern.FIRE_AND_FORGET,
payload: {
payloadKey: payload,
},
timeout: cdk.Duration.minutes(30),
});
// The code below shows an example of how to instantiate this type.
// The values are placeholders you should change.
import * as ec2 from '@aws-cdk/aws-ec2';
import * as stepfunctions from '@aws-cdk/aws-stepfunctions';
import * as stepfunctions_tasks from '@aws-cdk/aws-stepfunctions-tasks';
import * as cdk from '@aws-cdk/core';
declare const instanceType: ec2.InstanceType;
declare const payload: any;
const runBatchJobProps: stepfunctions_tasks.RunBatchJobProps = {
jobDefinitionArn: 'jobDefinitionArn',
jobName: 'jobName',
jobQueueArn: 'jobQueueArn',
// the properties below are optional
arraySize: 123,
attempts: 123,
containerOverrides: {
command: ['command'],
environment: {
environmentKey: 'environment',
},
gpuCount: 123,
instanceType: instanceType,
memory: 123,
vcpus: 123,
},
dependsOn: [{
jobId: 'jobId',
type: 'type',
}],
integrationPattern: stepfunctions.ServiceIntegrationPattern.FIRE_AND_FORGET,
payload: {
payloadKey: payload,
},
timeout: cdk.Duration.minutes(30),
};
// The code below shows an example of how to instantiate this type.
// The values are placeholders you should change.
import * as stepfunctions from '@aws-cdk/aws-stepfunctions';
import * as stepfunctions_tasks from '@aws-cdk/aws-stepfunctions-tasks';
import * as cdk from '@aws-cdk/core';
const runGlueJobTaskProps: stepfunctions_tasks.RunGlueJobTaskProps = {
arguments: {
argumentsKey: 'arguments',
},
integrationPattern: stepfunctions.ServiceIntegrationPattern.FIRE_AND_FORGET,
notifyDelayAfter: cdk.Duration.minutes(30),
securityConfiguration: 'securityConfiguration',
timeout: cdk.Duration.minutes(30),
};
// The code below shows an example of how to instantiate this type.
// The values are placeholders you should change.
import * as stepfunctions from '@aws-cdk/aws-stepfunctions';
import * as stepfunctions_tasks from '@aws-cdk/aws-stepfunctions-tasks';
declare const input: any;
declare const stateMachine: stepfunctions.StateMachine;
const startExecution = new stepfunctions_tasks.StartExecution(stateMachine, /* all optional props */ {
input: {
inputKey: input,
},
integrationPattern: stepfunctions.ServiceIntegrationPattern.FIRE_AND_FORGET,
name: 'name',
});