AWS stepfunctions Tasks

Get an Athena Query Execution as a Task.

Get an Athena Query Results as a Task.

Start an Athena Query as a Task.

Stop an Athena Query Execution as a Task.

Task to submits an AWS Batch job from a job definition.

A Step Functions Task to create model customization in Bedrock.

A Step Functions Task to invoke a model in Bedrock.

Call HTTP API endpoint as a Task.

Call REST API endpoint as a Task. Be aware that the header values must be arrays. When passing the Task Token in the headers field `WAIT_FOR_TASK_TOKEN` integration, use `JsonPath.array()` to wrap the token in an array: ```ts import * as apigateway from 'aws-cdk-lib/aws-apigateway'; declare const api: apigateway.RestApi; new tasks.CallApiGatewayRestApiEndpoint(this, 'Endpoint', { api, stageName: 'Stage', method: tasks.HttpMethod.PUT, integrationPattern: sfn.IntegrationPattern.WAIT_FOR_TASK_TOKEN, headers: sfn.TaskInput.fromObject({ TaskToken: sfn.JsonPath.array(sfn.JsonPath.taskToken), }), }); ```

A StepFunctions task to call an AWS service API.

A Step Functions task to call an AWS service API across regions. This task creates a Lambda function to call cross-region AWS API and invokes it.

Start a CodeBuild Build as a task.

Start a CodeBuild BatchBuild as a task.

A StepFunctions task to call DynamoDeleteItem.

A StepFunctions task to call DynamoGetItem.

A StepFunctions task to call DynamoPutItem.

A StepFunctions task to call DynamoUpdateItem.

Run a Task on ECS or Fargate.

Call a EKS endpoint as a Task.

A Step Functions Task to add a Step to an EMR Cluster. The StepConfiguration is defined as Parameters in the state machine definition. OUTPUT: the StepId

A Step Functions task to cancel a Step on an EMR Cluster.

Task that creates an EMR Containers virtual cluster from an EKS cluster.

Deletes an EMR Containers virtual cluster as a Task.

Starts a job run. A job is a unit of work that you submit to Amazon EMR on EKS for execution. The work performed by the job can be defined by a Spark jar, PySpark script, or SparkSQL query. A job run is an execution of the job on the virtual cluster.

A Step Functions Task to create an EMR Cluster. The ClusterConfiguration is defined as Parameters in the state machine definition. OUTPUT: the ClusterId.

A Step Functions Task to to modify an InstanceFleet on an EMR Cluster.

A Step Functions Task to to modify an InstanceGroup on an EMR Cluster.

A Step Functions Task to to set Termination Protection on an EMR Cluster.

A Step Functions Task to terminate an EMR Cluster.

A Step Functions Task to evaluate an expression. OUTPUT: the output of this task is the evaluated expression.

A StepFunctions Task to send events to an EventBridge event bus.

Create a new AWS EventBridge Scheduler schedule.

Start a Job run as a Task.

Starts an AWS Glue Crawler in a Task state.

Starts an AWS Glue job in a Task state. OUTPUT: the output of this task is a JobRun structure, for details consult https://docs.aws.amazon.com/glue/latest/dg/aws-glue-api-jobs-runs.html#aws-glue-api-jobs-runs-JobRun

A Step Functions Task to call a public third-party API.

Invoke a Lambda function as a Task.

A Step Functions Task to create a job in MediaConvert. The JobConfiguration/Request Syntax is defined in the Parameters in the Task State

A Step Functions Task to create a SageMaker endpoint.

A Step Functions Task to create a SageMaker endpoint configuration.

A Step Functions Task to create a SageMaker model.

Class representing the SageMaker Create Training Job task.

Class representing the SageMaker Create Transform Job task.

A Step Functions Task to update a SageMaker endpoint.

A Step Functions Task to publish messages to SNS topic.

A StepFunctions Task to send messages to SQS queue.

A Step Functions Task to invoke an Activity worker. An Activity can be used directly as a Resource.

A Step Functions Task to call StartExecution on another state machine. It supports three service integration patterns: REQUEST_RESPONSE, RUN_JOB, and WAIT_FOR_TASK_TOKEN.