Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- import { Context, ServiceIntegrationPattern, Task, TaskInput } from '@aws-cdk/aws-stepfunctions';
- import { SendToQueue } from '@aws-cdk/aws-stepfunctions-tasks';
- import { v4 as uuid } from 'uuid';
- const callbackTask = new Task(this, 'CallbackTask', {
- task: new SendToQueue(queue, {
- messageBody: TaskInput.fromObject({
- "id": uuid(),
- "taskToken": Context.taskToken,
- }),
- integrationPattern: ServiceIntegrationPattern.WAIT_FOR_TASK_TOKEN,
- }),
- });
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement