Interface MwaaServerlessClient

All Superinterfaces:

AutoCloseable, AwsClient, SdkAutoCloseable, SdkClient

@Generated("software.amazon.awssdk:codegen")
@SdkPublicApi
@ThreadSafe
public interface MwaaServerlessClient
extends AwsClient

Service client for accessing AmazonMWAAServerless. This can be created using the static builder() method.

Amazon Managed Workflows for Apache Airflow Serverless provides a managed workflow orchestration platform for running Apache Airflow workflows in a serverless environment. You can use Amazon Managed Workflows for Apache Airflow Serverless to create, manage, and run data processing workflows without managing the underlying infrastructure, Airflow clusters, metadata databases, or scheduling overhead. The service provides secure multi-tenant run environments with automatic scaling, comprehensive logging, and integration with multiple Amazon Web Services services for orchestrating complex analytics workloads.

Field Summary

Fields

Modifier and Type	Field	Description
static final String	SERVICE_METADATA_ID	Value for looking up the service's metadata from the ServiceMetadataProvider.
static final String	SERVICE_NAME

Method Summary

Modifier and Type	Method	Description
static MwaaServerlessClientBuilder	builder()	Create a builder that can be used to configure and create a MwaaServerlessClient.
static MwaaServerlessClient	create()	Create a MwaaServerlessClient with the region loaded from the DefaultAwsRegionProviderChain and credentials loaded from the DefaultCredentialsProvider.
default CreateWorkflowResponse	createWorkflow(Consumer<CreateWorkflowRequest.Builder> createWorkflowRequest)	Creates a new workflow in Amazon Managed Workflows for Apache Airflow Serverless.
default CreateWorkflowResponse	createWorkflow(CreateWorkflowRequest createWorkflowRequest)	Creates a new workflow in Amazon Managed Workflows for Apache Airflow Serverless.
default DeleteWorkflowResponse	deleteWorkflow(Consumer<DeleteWorkflowRequest.Builder> deleteWorkflowRequest)	Deletes a workflow and all its versions.
default DeleteWorkflowResponse	deleteWorkflow(DeleteWorkflowRequest deleteWorkflowRequest)	Deletes a workflow and all its versions.
default GetTaskInstanceResponse	getTaskInstance(Consumer<GetTaskInstanceRequest.Builder> getTaskInstanceRequest)	Retrieves detailed information about a specific task instance within a workflow run.
default GetTaskInstanceResponse	getTaskInstance(GetTaskInstanceRequest getTaskInstanceRequest)	Retrieves detailed information about a specific task instance within a workflow run.
default GetWorkflowResponse	getWorkflow(Consumer<GetWorkflowRequest.Builder> getWorkflowRequest)	Retrieves detailed information about a workflow, including its configuration, status, and metadata.
default GetWorkflowResponse	getWorkflow(GetWorkflowRequest getWorkflowRequest)	Retrieves detailed information about a workflow, including its configuration, status, and metadata.
default GetWorkflowRunResponse	getWorkflowRun(Consumer<GetWorkflowRunRequest.Builder> getWorkflowRunRequest)	Retrieves detailed information about a specific workflow run, including its status, execution details, and task instances.
default GetWorkflowRunResponse	getWorkflowRun(GetWorkflowRunRequest getWorkflowRunRequest)	Retrieves detailed information about a specific workflow run, including its status, execution details, and task instances.
default ListTagsForResourceResponse	listTagsForResource(Consumer<ListTagsForResourceRequest.Builder> listTagsForResourceRequest)	Lists all tags that are associated with a specified Amazon Managed Workflows for Apache Airflow Serverless resource.
default ListTagsForResourceResponse	listTagsForResource(ListTagsForResourceRequest listTagsForResourceRequest)	Lists all tags that are associated with a specified Amazon Managed Workflows for Apache Airflow Serverless resource.
default ListTaskInstancesResponse	listTaskInstances(Consumer<ListTaskInstancesRequest.Builder> listTaskInstancesRequest)	Lists all task instances for a specific workflow run, with optional pagination support.
default ListTaskInstancesResponse	listTaskInstances(ListTaskInstancesRequest listTaskInstancesRequest)	Lists all task instances for a specific workflow run, with optional pagination support.
default ListTaskInstancesIterable	listTaskInstancesPaginator(Consumer<ListTaskInstancesRequest.Builder> listTaskInstancesRequest)	This is a variant of listTaskInstances(software.amazon.awssdk.services.mwaaserverless.model.ListTaskInstancesRequest) operation.
default ListTaskInstancesIterable	listTaskInstancesPaginator(ListTaskInstancesRequest listTaskInstancesRequest)	This is a variant of listTaskInstances(software.amazon.awssdk.services.mwaaserverless.model.ListTaskInstancesRequest) operation.
default ListWorkflowRunsResponse	listWorkflowRuns(Consumer<ListWorkflowRunsRequest.Builder> listWorkflowRunsRequest)	Lists all runs for a specified workflow, with optional pagination and filtering support.
default ListWorkflowRunsResponse	listWorkflowRuns(ListWorkflowRunsRequest listWorkflowRunsRequest)	Lists all runs for a specified workflow, with optional pagination and filtering support.
default ListWorkflowRunsIterable	listWorkflowRunsPaginator(Consumer<ListWorkflowRunsRequest.Builder> listWorkflowRunsRequest)	This is a variant of listWorkflowRuns(software.amazon.awssdk.services.mwaaserverless.model.ListWorkflowRunsRequest) operation.
default ListWorkflowRunsIterable	listWorkflowRunsPaginator(ListWorkflowRunsRequest listWorkflowRunsRequest)	This is a variant of listWorkflowRuns(software.amazon.awssdk.services.mwaaserverless.model.ListWorkflowRunsRequest) operation.
default ListWorkflowsResponse	listWorkflows(Consumer<ListWorkflowsRequest.Builder> listWorkflowsRequest)	Lists all workflows in your account, with optional pagination support.
default ListWorkflowsResponse	listWorkflows(ListWorkflowsRequest listWorkflowsRequest)	Lists all workflows in your account, with optional pagination support.
default ListWorkflowsIterable	listWorkflowsPaginator(Consumer<ListWorkflowsRequest.Builder> listWorkflowsRequest)	This is a variant of listWorkflows(software.amazon.awssdk.services.mwaaserverless.model.ListWorkflowsRequest) operation.
default ListWorkflowsIterable	listWorkflowsPaginator(ListWorkflowsRequest listWorkflowsRequest)	This is a variant of listWorkflows(software.amazon.awssdk.services.mwaaserverless.model.ListWorkflowsRequest) operation.
default ListWorkflowVersionsResponse	listWorkflowVersions(Consumer<ListWorkflowVersionsRequest.Builder> listWorkflowVersionsRequest)	Lists all versions of a specified workflow, with optional pagination support.
default ListWorkflowVersionsResponse	listWorkflowVersions(ListWorkflowVersionsRequest listWorkflowVersionsRequest)	Lists all versions of a specified workflow, with optional pagination support.
default ListWorkflowVersionsIterable	listWorkflowVersionsPaginator(Consumer<ListWorkflowVersionsRequest.Builder> listWorkflowVersionsRequest)	This is a variant of listWorkflowVersions(software.amazon.awssdk.services.mwaaserverless.model.ListWorkflowVersionsRequest) operation.
default ListWorkflowVersionsIterable	listWorkflowVersionsPaginator(ListWorkflowVersionsRequest listWorkflowVersionsRequest)	This is a variant of listWorkflowVersions(software.amazon.awssdk.services.mwaaserverless.model.ListWorkflowVersionsRequest) operation.
default MwaaServerlessServiceClientConfiguration	serviceClientConfiguration()	The SDK service client configuration exposes client settings to the user, e.g., ClientOverrideConfiguration
static ServiceMetadata	serviceMetadata()
default StartWorkflowRunResponse	startWorkflowRun(Consumer<StartWorkflowRunRequest.Builder> startWorkflowRunRequest)	Starts a new execution of a workflow.
default StartWorkflowRunResponse	startWorkflowRun(StartWorkflowRunRequest startWorkflowRunRequest)	Starts a new execution of a workflow.
default StopWorkflowRunResponse	stopWorkflowRun(Consumer<StopWorkflowRunRequest.Builder> stopWorkflowRunRequest)	Stops a running workflow execution.
default StopWorkflowRunResponse	stopWorkflowRun(StopWorkflowRunRequest stopWorkflowRunRequest)	Stops a running workflow execution.
default TagResourceResponse	tagResource(Consumer<TagResourceRequest.Builder> tagResourceRequest)	Adds tags to an Amazon Managed Workflows for Apache Airflow Serverless resource.
default TagResourceResponse	tagResource(TagResourceRequest tagResourceRequest)	Adds tags to an Amazon Managed Workflows for Apache Airflow Serverless resource.
default UntagResourceResponse	untagResource(Consumer<UntagResourceRequest.Builder> untagResourceRequest)	Removes tags from an Amazon Managed Workflows for Apache Airflow Serverless resource.
default UntagResourceResponse	untagResource(UntagResourceRequest untagResourceRequest)	Removes tags from an Amazon Managed Workflows for Apache Airflow Serverless resource.
default UpdateWorkflowResponse	updateWorkflow(Consumer<UpdateWorkflowRequest.Builder> updateWorkflowRequest)	Updates an existing workflow with new configuration settings.
default UpdateWorkflowResponse	updateWorkflow(UpdateWorkflowRequest updateWorkflowRequest)	Updates an existing workflow with new configuration settings.

Methods inherited from interface software.amazon.awssdk.utils.SdkAutoCloseable

close

Methods inherited from interface software.amazon.awssdk.core.SdkClient

serviceName

Field Details

SERVICE_NAME

static final String SERVICE_NAME

See Also:

• Constant Field Values

SERVICE_METADATA_ID

static final String SERVICE_METADATA_ID

Value for looking up the service's metadata from the ServiceMetadataProvider.

See Also:

• Constant Field Values

Method Details

createWorkflow

default CreateWorkflowResponse createWorkflow(CreateWorkflowRequest createWorkflowRequest)
                                       throws ThrottlingException,
ValidationException,
AccessDeniedException,
InternalServerException,
OperationTimeoutException,
ConflictException,
ServiceQuotaExceededException,
AwsServiceException,
SdkClientException,
MwaaServerlessException

Creates a new workflow in Amazon Managed Workflows for Apache Airflow Serverless. This operation initializes a workflow with the specified configuration including the workflow definition, execution role, and optional settings for encryption, logging, and networking. You must provide the workflow definition as a YAML file stored in Amazon S3 that defines the DAG structure using supported Amazon Web Services operators. Amazon Managed Workflows for Apache Airflow Serverless automatically creates the first version of the workflow and sets up the necessary execution environment with multi-tenant isolation and security controls.

Parameters:

createWorkflowRequest -

Returns:

Result of the CreateWorkflow operation returned by the service.

See Also:

• AWS API Documentation

createWorkflow

default CreateWorkflowResponse createWorkflow(Consumer<CreateWorkflowRequest.Builder> createWorkflowRequest)
                                       throws ThrottlingException,
ValidationException,
AccessDeniedException,
InternalServerException,
OperationTimeoutException,
ConflictException,
ServiceQuotaExceededException,
AwsServiceException,
SdkClientException,
MwaaServerlessException

Creates a new workflow in Amazon Managed Workflows for Apache Airflow Serverless. This operation initializes a workflow with the specified configuration including the workflow definition, execution role, and optional settings for encryption, logging, and networking. You must provide the workflow definition as a YAML file stored in Amazon S3 that defines the DAG structure using supported Amazon Web Services operators. Amazon Managed Workflows for Apache Airflow Serverless automatically creates the first version of the workflow and sets up the necessary execution environment with multi-tenant isolation and security controls.

This is a convenience which creates an instance of the CreateWorkflowRequest.Builder avoiding the need to create one manually via CreateWorkflowRequest.builder()

Parameters:

createWorkflowRequest - A Consumer that will call methods on CreateWorkflowRequest.Builder to create a request.

Returns:

Result of the CreateWorkflow operation returned by the service.

See Also:

• AWS API Documentation

deleteWorkflow

default DeleteWorkflowResponse deleteWorkflow(DeleteWorkflowRequest deleteWorkflowRequest)
                                       throws ThrottlingException,
ValidationException,
ResourceNotFoundException,
AccessDeniedException,
InternalServerException,
OperationTimeoutException,
AwsServiceException,
SdkClientException,
MwaaServerlessException

Deletes a workflow and all its versions. This operation permanently removes the workflow and cannot be undone. Amazon Managed Workflows for Apache Airflow Serverless ensures that all associated resources are properly cleaned up, including stopping any running executions, removing scheduled triggers, and cleaning up execution history. The deletion process respects the multi-tenant isolation boundaries and ensures that no residual data or configurations remain that could affect other customers or workflows.

Parameters:

deleteWorkflowRequest -

Returns:

Result of the DeleteWorkflow operation returned by the service.

See Also:

• AWS API Documentation

deleteWorkflow

default DeleteWorkflowResponse deleteWorkflow(Consumer<DeleteWorkflowRequest.Builder> deleteWorkflowRequest)
                                       throws ThrottlingException,
ValidationException,
ResourceNotFoundException,
AccessDeniedException,
InternalServerException,
OperationTimeoutException,
AwsServiceException,
SdkClientException,
MwaaServerlessException

Deletes a workflow and all its versions. This operation permanently removes the workflow and cannot be undone. Amazon Managed Workflows for Apache Airflow Serverless ensures that all associated resources are properly cleaned up, including stopping any running executions, removing scheduled triggers, and cleaning up execution history. The deletion process respects the multi-tenant isolation boundaries and ensures that no residual data or configurations remain that could affect other customers or workflows.

This is a convenience which creates an instance of the DeleteWorkflowRequest.Builder avoiding the need to create one manually via DeleteWorkflowRequest.builder()

Parameters:

deleteWorkflowRequest - A Consumer that will call methods on DeleteWorkflowRequest.Builder to create a request.

Returns:

Result of the DeleteWorkflow operation returned by the service.

See Also:

• AWS API Documentation

getTaskInstance

default GetTaskInstanceResponse getTaskInstance(GetTaskInstanceRequest getTaskInstanceRequest)
                                         throws ThrottlingException,
ValidationException,
ResourceNotFoundException,
AccessDeniedException,
InternalServerException,
OperationTimeoutException,
AwsServiceException,
SdkClientException,
MwaaServerlessException

Retrieves detailed information about a specific task instance within a workflow run. Task instances represent individual tasks that are executed as part of a workflow in the Amazon Managed Workflows for Apache Airflow Serverless environment. Each task instance runs in an isolated ECS container with dedicated resources and security boundaries. The service tracks task execution state, retry attempts, and provides detailed timing and error information for troubleshooting and monitoring purposes.

Parameters:

getTaskInstanceRequest -

Returns:

Result of the GetTaskInstance operation returned by the service.

See Also:

• AWS API Documentation

getTaskInstance

default GetTaskInstanceResponse getTaskInstance(Consumer<GetTaskInstanceRequest.Builder> getTaskInstanceRequest)
                                         throws ThrottlingException,
ValidationException,
ResourceNotFoundException,
AccessDeniedException,
InternalServerException,
OperationTimeoutException,
AwsServiceException,
SdkClientException,
MwaaServerlessException

Retrieves detailed information about a specific task instance within a workflow run. Task instances represent individual tasks that are executed as part of a workflow in the Amazon Managed Workflows for Apache Airflow Serverless environment. Each task instance runs in an isolated ECS container with dedicated resources and security boundaries. The service tracks task execution state, retry attempts, and provides detailed timing and error information for troubleshooting and monitoring purposes.

This is a convenience which creates an instance of the GetTaskInstanceRequest.Builder avoiding the need to create one manually via GetTaskInstanceRequest.builder()

Parameters:

getTaskInstanceRequest - A Consumer that will call methods on GetTaskInstanceRequest.Builder to create a request.

Returns:

Result of the GetTaskInstance operation returned by the service.

See Also:

• AWS API Documentation

getWorkflow

default GetWorkflowResponse getWorkflow(GetWorkflowRequest getWorkflowRequest)
                                 throws ThrottlingException,
ValidationException,
ResourceNotFoundException,
AccessDeniedException,
InternalServerException,
OperationTimeoutException,
AwsServiceException,
SdkClientException,
MwaaServerlessException

Retrieves detailed information about a workflow, including its configuration, status, and metadata.

Parameters:

getWorkflowRequest -

Returns:

Result of the GetWorkflow operation returned by the service.

See Also:

• AWS API Documentation

getWorkflow

default GetWorkflowResponse getWorkflow(Consumer<GetWorkflowRequest.Builder> getWorkflowRequest)
                                 throws ThrottlingException,
ValidationException,
ResourceNotFoundException,
AccessDeniedException,
InternalServerException,
OperationTimeoutException,
AwsServiceException,
SdkClientException,
MwaaServerlessException

Retrieves detailed information about a workflow, including its configuration, status, and metadata.

This is a convenience which creates an instance of the GetWorkflowRequest.Builder avoiding the need to create one manually via GetWorkflowRequest.builder()

Parameters:

getWorkflowRequest - A Consumer that will call methods on GetWorkflowRequest.Builder to create a request.

Returns:

Result of the GetWorkflow operation returned by the service.

See Also:

• AWS API Documentation

getWorkflowRun

default GetWorkflowRunResponse getWorkflowRun(GetWorkflowRunRequest getWorkflowRunRequest)
                                       throws ThrottlingException,
ValidationException,
ResourceNotFoundException,
AccessDeniedException,
InternalServerException,
OperationTimeoutException,
AwsServiceException,
SdkClientException,
MwaaServerlessException

Retrieves detailed information about a specific workflow run, including its status, execution details, and task instances.

Parameters:

getWorkflowRunRequest -

Returns:

Result of the GetWorkflowRun operation returned by the service.

See Also:

• AWS API Documentation

getWorkflowRun

default GetWorkflowRunResponse getWorkflowRun(Consumer<GetWorkflowRunRequest.Builder> getWorkflowRunRequest)
                                       throws ThrottlingException,
ValidationException,
ResourceNotFoundException,
AccessDeniedException,
InternalServerException,
OperationTimeoutException,
AwsServiceException,
SdkClientException,
MwaaServerlessException

Retrieves detailed information about a specific workflow run, including its status, execution details, and task instances.

This is a convenience which creates an instance of the GetWorkflowRunRequest.Builder avoiding the need to create one manually via GetWorkflowRunRequest.builder()

Parameters:

getWorkflowRunRequest - A Consumer that will call methods on GetWorkflowRunRequest.Builder to create a request.

Returns:

Result of the GetWorkflowRun operation returned by the service.

See Also:

• AWS API Documentation

listTagsForResource

default ListTagsForResourceResponse listTagsForResource(ListTagsForResourceRequest listTagsForResourceRequest)
                                                 throws ThrottlingException,
ValidationException,
ResourceNotFoundException,
AccessDeniedException,
InternalServerException,
OperationTimeoutException,
AwsServiceException,
SdkClientException,
MwaaServerlessException

Lists all tags that are associated with a specified Amazon Managed Workflows for Apache Airflow Serverless resource.

Parameters:

listTagsForResourceRequest -

Returns:

Result of the ListTagsForResource operation returned by the service.

See Also:

• AWS API Documentation

listTagsForResource

default ListTagsForResourceResponse listTagsForResource(Consumer<ListTagsForResourceRequest.Builder> listTagsForResourceRequest)
                                                 throws ThrottlingException,
ValidationException,
ResourceNotFoundException,
AccessDeniedException,
InternalServerException,
OperationTimeoutException,
AwsServiceException,
SdkClientException,
MwaaServerlessException

Lists all tags that are associated with a specified Amazon Managed Workflows for Apache Airflow Serverless resource.

This is a convenience which creates an instance of the ListTagsForResourceRequest.Builder avoiding the need to create one manually via ListTagsForResourceRequest.builder()

Parameters:

listTagsForResourceRequest - A Consumer that will call methods on ListTagsForResourceRequest.Builder to create a request.

Returns:

Result of the ListTagsForResource operation returned by the service.

See Also:

• AWS API Documentation

listTaskInstances

default ListTaskInstancesResponse listTaskInstances(ListTaskInstancesRequest listTaskInstancesRequest)
                                             throws ThrottlingException,
ValidationException,
AccessDeniedException,
InternalServerException,
OperationTimeoutException,
AwsServiceException,
SdkClientException,
MwaaServerlessException

Lists all task instances for a specific workflow run, with optional pagination support.

Parameters:

listTaskInstancesRequest -

Returns:

Result of the ListTaskInstances operation returned by the service.

See Also:

• AWS API Documentation

listTaskInstances

default ListTaskInstancesResponse listTaskInstances(Consumer<ListTaskInstancesRequest.Builder> listTaskInstancesRequest)
                                             throws ThrottlingException,
ValidationException,
AccessDeniedException,
InternalServerException,
OperationTimeoutException,
AwsServiceException,
SdkClientException,
MwaaServerlessException

Lists all task instances for a specific workflow run, with optional pagination support.

This is a convenience which creates an instance of the ListTaskInstancesRequest.Builder avoiding the need to create one manually via ListTaskInstancesRequest.builder()

Parameters:

listTaskInstancesRequest - A Consumer that will call methods on ListTaskInstancesRequest.Builder to create a request.

Returns:

Result of the ListTaskInstances operation returned by the service.

See Also:

• AWS API Documentation

listTaskInstancesPaginator

default ListTaskInstancesIterable listTaskInstancesPaginator(ListTaskInstancesRequest listTaskInstancesRequest)
                                                      throws ThrottlingException,
ValidationException,
AccessDeniedException,
InternalServerException,
OperationTimeoutException,
AwsServiceException,
SdkClientException,
MwaaServerlessException

This is a variant of listTaskInstances(software.amazon.awssdk.services.mwaaserverless.model.ListTaskInstancesRequest) operation. The return type is a custom iterable that can be used to iterate through all the pages. SDK will internally handle making service calls for you.

When this operation is called, a custom iterable is returned but no service calls are made yet. So there is no guarantee that the request is valid. As you iterate through the iterable, SDK will start lazily loading response pages by making service calls until there are no pages left or your iteration stops. If there are errors in your request, you will see the failures only after you start iterating through the iterable.

The following are few ways to iterate through the response pages:

1) Using a Stream

 
 software.amazon.awssdk.services.mwaaserverless.paginators.ListTaskInstancesIterable responses = client.listTaskInstancesPaginator(request);
 responses.stream().forEach(....);
 
 

2) Using For loop

 {
     @code
     software.amazon.awssdk.services.mwaaserverless.paginators.ListTaskInstancesIterable responses = client
             .listTaskInstancesPaginator(request);
     for (software.amazon.awssdk.services.mwaaserverless.model.ListTaskInstancesResponse response : responses) {
         // do something;
     }
 }
 

3) Use iterator directly

 
 software.amazon.awssdk.services.mwaaserverless.paginators.ListTaskInstancesIterable responses = client.listTaskInstancesPaginator(request);
 responses.iterator().forEachRemaining(....);
 
 

Please notice that the configuration of MaxResults won't limit the number of results you get with the paginator. It only limits the number of results in each page.

Note: If you prefer to have control on service calls, use the listTaskInstances(software.amazon.awssdk.services.mwaaserverless.model.ListTaskInstancesRequest) operation.

Parameters:

listTaskInstancesRequest -

Returns:

A custom iterable that can be used to iterate through all the response pages.

See Also:

• AWS API Documentation

listTaskInstancesPaginator

default ListTaskInstancesIterable listTaskInstancesPaginator(Consumer<ListTaskInstancesRequest.Builder> listTaskInstancesRequest)
                                                      throws ThrottlingException,
ValidationException,
AccessDeniedException,
InternalServerException,
OperationTimeoutException,
AwsServiceException,
SdkClientException,
MwaaServerlessException

This is a variant of listTaskInstances(software.amazon.awssdk.services.mwaaserverless.model.ListTaskInstancesRequest) operation. The return type is a custom iterable that can be used to iterate through all the pages. SDK will internally handle making service calls for you.

When this operation is called, a custom iterable is returned but no service calls are made yet. So there is no guarantee that the request is valid. As you iterate through the iterable, SDK will start lazily loading response pages by making service calls until there are no pages left or your iteration stops. If there are errors in your request, you will see the failures only after you start iterating through the iterable.

The following are few ways to iterate through the response pages:

1) Using a Stream

 
 software.amazon.awssdk.services.mwaaserverless.paginators.ListTaskInstancesIterable responses = client.listTaskInstancesPaginator(request);
 responses.stream().forEach(....);
 
 

2) Using For loop

 {
     @code
     software.amazon.awssdk.services.mwaaserverless.paginators.ListTaskInstancesIterable responses = client
             .listTaskInstancesPaginator(request);
     for (software.amazon.awssdk.services.mwaaserverless.model.ListTaskInstancesResponse response : responses) {
         // do something;
     }
 }
 

3) Use iterator directly

 
 software.amazon.awssdk.services.mwaaserverless.paginators.ListTaskInstancesIterable responses = client.listTaskInstancesPaginator(request);
 responses.iterator().forEachRemaining(....);
 
 

Please notice that the configuration of MaxResults won't limit the number of results you get with the paginator. It only limits the number of results in each page.

Note: If you prefer to have control on service calls, use the listTaskInstances(software.amazon.awssdk.services.mwaaserverless.model.ListTaskInstancesRequest) operation.

This is a convenience which creates an instance of the ListTaskInstancesRequest.Builder avoiding the need to create one manually via ListTaskInstancesRequest.builder()

Parameters:

listTaskInstancesRequest - A Consumer that will call methods on ListTaskInstancesRequest.Builder to create a request.

Returns:

A custom iterable that can be used to iterate through all the response pages.

See Also:

• AWS API Documentation

listWorkflowRuns

default ListWorkflowRunsResponse listWorkflowRuns(ListWorkflowRunsRequest listWorkflowRunsRequest)
                                           throws ThrottlingException,
ValidationException,
AccessDeniedException,
InternalServerException,
OperationTimeoutException,
AwsServiceException,
SdkClientException,
MwaaServerlessException

Lists all runs for a specified workflow, with optional pagination and filtering support.

Parameters:

listWorkflowRunsRequest -

Returns:

Result of the ListWorkflowRuns operation returned by the service.

See Also:

• AWS API Documentation

listWorkflowRuns

default ListWorkflowRunsResponse listWorkflowRuns(Consumer<ListWorkflowRunsRequest.Builder> listWorkflowRunsRequest)
                                           throws ThrottlingException,
ValidationException,
AccessDeniedException,
InternalServerException,
OperationTimeoutException,
AwsServiceException,
SdkClientException,
MwaaServerlessException

Lists all runs for a specified workflow, with optional pagination and filtering support.

This is a convenience which creates an instance of the ListWorkflowRunsRequest.Builder avoiding the need to create one manually via ListWorkflowRunsRequest.builder()

Parameters:

listWorkflowRunsRequest - A Consumer that will call methods on ListWorkflowRunsRequest.Builder to create a request.

Returns:

Result of the ListWorkflowRuns operation returned by the service.

See Also:

• AWS API Documentation

listWorkflowRunsPaginator

default ListWorkflowRunsIterable listWorkflowRunsPaginator(ListWorkflowRunsRequest listWorkflowRunsRequest)
                                                    throws ThrottlingException,
ValidationException,
AccessDeniedException,
InternalServerException,
OperationTimeoutException,
AwsServiceException,
SdkClientException,
MwaaServerlessException

This is a variant of listWorkflowRuns(software.amazon.awssdk.services.mwaaserverless.model.ListWorkflowRunsRequest) operation. The return type is a custom iterable that can be used to iterate through all the pages. SDK will internally handle making service calls for you.

When this operation is called, a custom iterable is returned but no service calls are made yet. So there is no guarantee that the request is valid. As you iterate through the iterable, SDK will start lazily loading response pages by making service calls until there are no pages left or your iteration stops. If there are errors in your request, you will see the failures only after you start iterating through the iterable.

The following are few ways to iterate through the response pages:

1) Using a Stream

 
 software.amazon.awssdk.services.mwaaserverless.paginators.ListWorkflowRunsIterable responses = client.listWorkflowRunsPaginator(request);
 responses.stream().forEach(....);
 
 

2) Using For loop

 {
     @code
     software.amazon.awssdk.services.mwaaserverless.paginators.ListWorkflowRunsIterable responses = client
             .listWorkflowRunsPaginator(request);
     for (software.amazon.awssdk.services.mwaaserverless.model.ListWorkflowRunsResponse response : responses) {
         // do something;
     }
 }
 

3) Use iterator directly

 
 software.amazon.awssdk.services.mwaaserverless.paginators.ListWorkflowRunsIterable responses = client.listWorkflowRunsPaginator(request);
 responses.iterator().forEachRemaining(....);
 
 

Please notice that the configuration of MaxResults won't limit the number of results you get with the paginator. It only limits the number of results in each page.

Note: If you prefer to have control on service calls, use the listWorkflowRuns(software.amazon.awssdk.services.mwaaserverless.model.ListWorkflowRunsRequest) operation.

Parameters:

listWorkflowRunsRequest -

Returns:

A custom iterable that can be used to iterate through all the response pages.

See Also:

• AWS API Documentation

listWorkflowRunsPaginator

default ListWorkflowRunsIterable listWorkflowRunsPaginator(Consumer<ListWorkflowRunsRequest.Builder> listWorkflowRunsRequest)
                                                    throws ThrottlingException,
ValidationException,
AccessDeniedException,
InternalServerException,
OperationTimeoutException,
AwsServiceException,
SdkClientException,
MwaaServerlessException

This is a variant of listWorkflowRuns(software.amazon.awssdk.services.mwaaserverless.model.ListWorkflowRunsRequest) operation. The return type is a custom iterable that can be used to iterate through all the pages. SDK will internally handle making service calls for you.

When this operation is called, a custom iterable is returned but no service calls are made yet. So there is no guarantee that the request is valid. As you iterate through the iterable, SDK will start lazily loading response pages by making service calls until there are no pages left or your iteration stops. If there are errors in your request, you will see the failures only after you start iterating through the iterable.

The following are few ways to iterate through the response pages:

1) Using a Stream

 
 software.amazon.awssdk.services.mwaaserverless.paginators.ListWorkflowRunsIterable responses = client.listWorkflowRunsPaginator(request);
 responses.stream().forEach(....);
 
 

2) Using For loop

 {
     @code
     software.amazon.awssdk.services.mwaaserverless.paginators.ListWorkflowRunsIterable responses = client
             .listWorkflowRunsPaginator(request);
     for (software.amazon.awssdk.services.mwaaserverless.model.ListWorkflowRunsResponse response : responses) {
         // do something;
     }
 }
 

3) Use iterator directly

 
 software.amazon.awssdk.services.mwaaserverless.paginators.ListWorkflowRunsIterable responses = client.listWorkflowRunsPaginator(request);
 responses.iterator().forEachRemaining(....);
 
 

Please notice that the configuration of MaxResults won't limit the number of results you get with the paginator. It only limits the number of results in each page.

Note: If you prefer to have control on service calls, use the listWorkflowRuns(software.amazon.awssdk.services.mwaaserverless.model.ListWorkflowRunsRequest) operation.

This is a convenience which creates an instance of the ListWorkflowRunsRequest.Builder avoiding the need to create one manually via ListWorkflowRunsRequest.builder()

Parameters:

listWorkflowRunsRequest - A Consumer that will call methods on ListWorkflowRunsRequest.Builder to create a request.

Returns:

A custom iterable that can be used to iterate through all the response pages.

See Also:

• AWS API Documentation

listWorkflowVersions

default ListWorkflowVersionsResponse listWorkflowVersions(ListWorkflowVersionsRequest listWorkflowVersionsRequest)
                                                   throws ThrottlingException,
ValidationException,
AccessDeniedException,
InternalServerException,
OperationTimeoutException,
AwsServiceException,
SdkClientException,
MwaaServerlessException

Lists all versions of a specified workflow, with optional pagination support.

Parameters:

listWorkflowVersionsRequest -

Returns:

Result of the ListWorkflowVersions operation returned by the service.

See Also:

• AWS API Documentation

listWorkflowVersions

default ListWorkflowVersionsResponse listWorkflowVersions(Consumer<ListWorkflowVersionsRequest.Builder> listWorkflowVersionsRequest)
                                                   throws ThrottlingException,
ValidationException,
AccessDeniedException,
InternalServerException,
OperationTimeoutException,
AwsServiceException,
SdkClientException,
MwaaServerlessException

Lists all versions of a specified workflow, with optional pagination support.

This is a convenience which creates an instance of the ListWorkflowVersionsRequest.Builder avoiding the need to create one manually via ListWorkflowVersionsRequest.builder()

Parameters:

listWorkflowVersionsRequest - A Consumer that will call methods on ListWorkflowVersionsRequest.Builder to create a request.

Returns:

Result of the ListWorkflowVersions operation returned by the service.

See Also:

• AWS API Documentation

listWorkflowVersionsPaginator

default ListWorkflowVersionsIterable listWorkflowVersionsPaginator(ListWorkflowVersionsRequest listWorkflowVersionsRequest)
                                                            throws ThrottlingException,
ValidationException,
AccessDeniedException,
InternalServerException,
OperationTimeoutException,
AwsServiceException,
SdkClientException,
MwaaServerlessException

This is a variant of listWorkflowVersions(software.amazon.awssdk.services.mwaaserverless.model.ListWorkflowVersionsRequest) operation. The return type is a custom iterable that can be used to iterate through all the pages. SDK will internally handle making service calls for you.

When this operation is called, a custom iterable is returned but no service calls are made yet. So there is no guarantee that the request is valid. As you iterate through the iterable, SDK will start lazily loading response pages by making service calls until there are no pages left or your iteration stops. If there are errors in your request, you will see the failures only after you start iterating through the iterable.

The following are few ways to iterate through the response pages:

1) Using a Stream

 
 software.amazon.awssdk.services.mwaaserverless.paginators.ListWorkflowVersionsIterable responses = client.listWorkflowVersionsPaginator(request);
 responses.stream().forEach(....);
 
 

2) Using For loop

 {
     @code
     software.amazon.awssdk.services.mwaaserverless.paginators.ListWorkflowVersionsIterable responses = client
             .listWorkflowVersionsPaginator(request);
     for (software.amazon.awssdk.services.mwaaserverless.model.ListWorkflowVersionsResponse response : responses) {
         // do something;
     }
 }
 

3) Use iterator directly

 
 software.amazon.awssdk.services.mwaaserverless.paginators.ListWorkflowVersionsIterable responses = client.listWorkflowVersionsPaginator(request);
 responses.iterator().forEachRemaining(....);
 
 

Please notice that the configuration of MaxResults won't limit the number of results you get with the paginator. It only limits the number of results in each page.

Note: If you prefer to have control on service calls, use the listWorkflowVersions(software.amazon.awssdk.services.mwaaserverless.model.ListWorkflowVersionsRequest) operation.

Parameters:

listWorkflowVersionsRequest -

Returns:

A custom iterable that can be used to iterate through all the response pages.

See Also:

• AWS API Documentation

listWorkflowVersionsPaginator

default ListWorkflowVersionsIterable listWorkflowVersionsPaginator(Consumer<ListWorkflowVersionsRequest.Builder> listWorkflowVersionsRequest)
                                                            throws ThrottlingException,
ValidationException,
AccessDeniedException,
InternalServerException,
OperationTimeoutException,
AwsServiceException,
SdkClientException,
MwaaServerlessException

This is a variant of listWorkflowVersions(software.amazon.awssdk.services.mwaaserverless.model.ListWorkflowVersionsRequest) operation. The return type is a custom iterable that can be used to iterate through all the pages. SDK will internally handle making service calls for you.

When this operation is called, a custom iterable is returned but no service calls are made yet. So there is no guarantee that the request is valid. As you iterate through the iterable, SDK will start lazily loading response pages by making service calls until there are no pages left or your iteration stops. If there are errors in your request, you will see the failures only after you start iterating through the iterable.

The following are few ways to iterate through the response pages:

1) Using a Stream

 
 software.amazon.awssdk.services.mwaaserverless.paginators.ListWorkflowVersionsIterable responses = client.listWorkflowVersionsPaginator(request);
 responses.stream().forEach(....);
 
 

2) Using For loop

 {
     @code
     software.amazon.awssdk.services.mwaaserverless.paginators.ListWorkflowVersionsIterable responses = client
             .listWorkflowVersionsPaginator(request);
     for (software.amazon.awssdk.services.mwaaserverless.model.ListWorkflowVersionsResponse response : responses) {
         // do something;
     }
 }
 

3) Use iterator directly

 
 software.amazon.awssdk.services.mwaaserverless.paginators.ListWorkflowVersionsIterable responses = client.listWorkflowVersionsPaginator(request);
 responses.iterator().forEachRemaining(....);
 
 

Please notice that the configuration of MaxResults won't limit the number of results you get with the paginator. It only limits the number of results in each page.

Note: If you prefer to have control on service calls, use the listWorkflowVersions(software.amazon.awssdk.services.mwaaserverless.model.ListWorkflowVersionsRequest) operation.

This is a convenience which creates an instance of the ListWorkflowVersionsRequest.Builder avoiding the need to create one manually via ListWorkflowVersionsRequest.builder()

Parameters:

listWorkflowVersionsRequest - A Consumer that will call methods on ListWorkflowVersionsRequest.Builder to create a request.

Returns:

A custom iterable that can be used to iterate through all the response pages.

See Also:

• AWS API Documentation

listWorkflows

default ListWorkflowsResponse listWorkflows(ListWorkflowsRequest listWorkflowsRequest)
                                     throws ThrottlingException,
ValidationException,
AccessDeniedException,
InternalServerException,
OperationTimeoutException,
AwsServiceException,
SdkClientException,
MwaaServerlessException

Lists all workflows in your account, with optional pagination support. This operation returns summary information for workflows, showing only the most recently created version of each workflow. Amazon Managed Workflows for Apache Airflow Serverless maintains workflow metadata in a highly available, distributed storage system that enables efficient querying and filtering. The service implements proper access controls to ensure you can only view workflows that you have permissions to access, supporting both individual and team-based workflow management scenarios.

Parameters:

listWorkflowsRequest -

Returns:

Result of the ListWorkflows operation returned by the service.

See Also:

• AWS API Documentation

listWorkflows

default ListWorkflowsResponse listWorkflows(Consumer<ListWorkflowsRequest.Builder> listWorkflowsRequest)
                                     throws ThrottlingException,
ValidationException,
AccessDeniedException,
InternalServerException,
OperationTimeoutException,
AwsServiceException,
SdkClientException,
MwaaServerlessException

Lists all workflows in your account, with optional pagination support. This operation returns summary information for workflows, showing only the most recently created version of each workflow. Amazon Managed Workflows for Apache Airflow Serverless maintains workflow metadata in a highly available, distributed storage system that enables efficient querying and filtering. The service implements proper access controls to ensure you can only view workflows that you have permissions to access, supporting both individual and team-based workflow management scenarios.

This is a convenience which creates an instance of the ListWorkflowsRequest.Builder avoiding the need to create one manually via ListWorkflowsRequest.builder()

Parameters:

listWorkflowsRequest - A Consumer that will call methods on ListWorkflowsRequest.Builder to create a request.

Returns:

Result of the ListWorkflows operation returned by the service.

See Also:

• AWS API Documentation

listWorkflowsPaginator

default ListWorkflowsIterable listWorkflowsPaginator(ListWorkflowsRequest listWorkflowsRequest)
                                              throws ThrottlingException,
ValidationException,
AccessDeniedException,
InternalServerException,
OperationTimeoutException,
AwsServiceException,
SdkClientException,
MwaaServerlessException

This is a variant of listWorkflows(software.amazon.awssdk.services.mwaaserverless.model.ListWorkflowsRequest) operation. The return type is a custom iterable that can be used to iterate through all the pages. SDK will internally handle making service calls for you.

When this operation is called, a custom iterable is returned but no service calls are made yet. So there is no guarantee that the request is valid. As you iterate through the iterable, SDK will start lazily loading response pages by making service calls until there are no pages left or your iteration stops. If there are errors in your request, you will see the failures only after you start iterating through the iterable.

The following are few ways to iterate through the response pages:

1) Using a Stream

 
 software.amazon.awssdk.services.mwaaserverless.paginators.ListWorkflowsIterable responses = client.listWorkflowsPaginator(request);
 responses.stream().forEach(....);
 
 

2) Using For loop

 {
     @code
     software.amazon.awssdk.services.mwaaserverless.paginators.ListWorkflowsIterable responses = client
             .listWorkflowsPaginator(request);
     for (software.amazon.awssdk.services.mwaaserverless.model.ListWorkflowsResponse response : responses) {
         // do something;
     }
 }
 

3) Use iterator directly

 
 software.amazon.awssdk.services.mwaaserverless.paginators.ListWorkflowsIterable responses = client.listWorkflowsPaginator(request);
 responses.iterator().forEachRemaining(....);
 
 

Please notice that the configuration of MaxResults won't limit the number of results you get with the paginator. It only limits the number of results in each page.

Note: If you prefer to have control on service calls, use the listWorkflows(software.amazon.awssdk.services.mwaaserverless.model.ListWorkflowsRequest) operation.

Parameters:

listWorkflowsRequest -

Returns:

A custom iterable that can be used to iterate through all the response pages.

See Also:

• AWS API Documentation

listWorkflowsPaginator

default ListWorkflowsIterable listWorkflowsPaginator(Consumer<ListWorkflowsRequest.Builder> listWorkflowsRequest)
                                              throws ThrottlingException,
ValidationException,
AccessDeniedException,
InternalServerException,
OperationTimeoutException,
AwsServiceException,
SdkClientException,
MwaaServerlessException

This is a variant of listWorkflows(software.amazon.awssdk.services.mwaaserverless.model.ListWorkflowsRequest) operation. The return type is a custom iterable that can be used to iterate through all the pages. SDK will internally handle making service calls for you.

When this operation is called, a custom iterable is returned but no service calls are made yet. So there is no guarantee that the request is valid. As you iterate through the iterable, SDK will start lazily loading response pages by making service calls until there are no pages left or your iteration stops. If there are errors in your request, you will see the failures only after you start iterating through the iterable.

The following are few ways to iterate through the response pages:

1) Using a Stream

 
 software.amazon.awssdk.services.mwaaserverless.paginators.ListWorkflowsIterable responses = client.listWorkflowsPaginator(request);
 responses.stream().forEach(....);
 
 

2) Using For loop

 {
     @code
     software.amazon.awssdk.services.mwaaserverless.paginators.ListWorkflowsIterable responses = client
             .listWorkflowsPaginator(request);
     for (software.amazon.awssdk.services.mwaaserverless.model.ListWorkflowsResponse response : responses) {
         // do something;
     }
 }
 

3) Use iterator directly

 
 software.amazon.awssdk.services.mwaaserverless.paginators.ListWorkflowsIterable responses = client.listWorkflowsPaginator(request);
 responses.iterator().forEachRemaining(....);
 
 

Please notice that the configuration of MaxResults won't limit the number of results you get with the paginator. It only limits the number of results in each page.

Note: If you prefer to have control on service calls, use the listWorkflows(software.amazon.awssdk.services.mwaaserverless.model.ListWorkflowsRequest) operation.

This is a convenience which creates an instance of the ListWorkflowsRequest.Builder avoiding the need to create one manually via ListWorkflowsRequest.builder()

Parameters:

listWorkflowsRequest - A Consumer that will call methods on ListWorkflowsRequest.Builder to create a request.

Returns:

A custom iterable that can be used to iterate through all the response pages.

See Also:

• AWS API Documentation

startWorkflowRun

default StartWorkflowRunResponse startWorkflowRun(StartWorkflowRunRequest startWorkflowRunRequest)
                                           throws ThrottlingException,
ValidationException,
ResourceNotFoundException,
AccessDeniedException,
InternalServerException,
OperationTimeoutException,
ConflictException,
ServiceQuotaExceededException,
AwsServiceException,
SdkClientException,
MwaaServerlessException

Starts a new execution of a workflow. This operation creates a workflow run that executes the tasks that are defined in the workflow. Amazon Managed Workflows for Apache Airflow Serverless schedules the workflow execution across its managed Airflow environment, automatically scaling ECS worker tasks based on the workload. The service handles task isolation, dependency resolution, and provides comprehensive monitoring and logging throughout the execution lifecycle.

Parameters:

startWorkflowRunRequest -

Returns:

Result of the StartWorkflowRun operation returned by the service.

See Also:

• AWS API Documentation

startWorkflowRun

default StartWorkflowRunResponse startWorkflowRun(Consumer<StartWorkflowRunRequest.Builder> startWorkflowRunRequest)
                                           throws ThrottlingException,
ValidationException,
ResourceNotFoundException,
AccessDeniedException,
InternalServerException,
OperationTimeoutException,
ConflictException,
ServiceQuotaExceededException,
AwsServiceException,
SdkClientException,
MwaaServerlessException

Starts a new execution of a workflow. This operation creates a workflow run that executes the tasks that are defined in the workflow. Amazon Managed Workflows for Apache Airflow Serverless schedules the workflow execution across its managed Airflow environment, automatically scaling ECS worker tasks based on the workload. The service handles task isolation, dependency resolution, and provides comprehensive monitoring and logging throughout the execution lifecycle.

This is a convenience which creates an instance of the StartWorkflowRunRequest.Builder avoiding the need to create one manually via StartWorkflowRunRequest.builder()

Parameters:

startWorkflowRunRequest - A Consumer that will call methods on StartWorkflowRunRequest.Builder to create a request.

Returns:

Result of the StartWorkflowRun operation returned by the service.

See Also:

• AWS API Documentation

stopWorkflowRun

default StopWorkflowRunResponse stopWorkflowRun(StopWorkflowRunRequest stopWorkflowRunRequest)
                                         throws ThrottlingException,
ValidationException,
ResourceNotFoundException,
AccessDeniedException,
InternalServerException,
OperationTimeoutException,
AwsServiceException,
SdkClientException,
MwaaServerlessException

Stops a running workflow execution. This operation terminates all running tasks and prevents new tasks from starting. Amazon Managed Workflows for Apache Airflow Serverless gracefully shuts down the workflow execution by stopping task scheduling and terminating active ECS worker containers. The operation transitions the workflow run to a STOPPING state and then to STOPPED once all cleanup is complete. In-flight tasks may complete or be terminated depending on their current execution state.

Parameters:

stopWorkflowRunRequest -

Returns:

Result of the StopWorkflowRun operation returned by the service.

See Also:

• AWS API Documentation

stopWorkflowRun

default StopWorkflowRunResponse stopWorkflowRun(Consumer<StopWorkflowRunRequest.Builder> stopWorkflowRunRequest)
                                         throws ThrottlingException,
ValidationException,
ResourceNotFoundException,
AccessDeniedException,
InternalServerException,
OperationTimeoutException,
AwsServiceException,
SdkClientException,
MwaaServerlessException

Stops a running workflow execution. This operation terminates all running tasks and prevents new tasks from starting. Amazon Managed Workflows for Apache Airflow Serverless gracefully shuts down the workflow execution by stopping task scheduling and terminating active ECS worker containers. The operation transitions the workflow run to a STOPPING state and then to STOPPED once all cleanup is complete. In-flight tasks may complete or be terminated depending on their current execution state.

This is a convenience which creates an instance of the StopWorkflowRunRequest.Builder avoiding the need to create one manually via StopWorkflowRunRequest.builder()

Parameters:

stopWorkflowRunRequest - A Consumer that will call methods on StopWorkflowRunRequest.Builder to create a request.

Returns:

Result of the StopWorkflowRun operation returned by the service.

See Also:

• AWS API Documentation

tagResource

default TagResourceResponse tagResource(TagResourceRequest tagResourceRequest)
                                 throws ThrottlingException,
ValidationException,
ResourceNotFoundException,
AccessDeniedException,
InternalServerException,
OperationTimeoutException,
AwsServiceException,
SdkClientException,
MwaaServerlessException

Adds tags to an Amazon Managed Workflows for Apache Airflow Serverless resource. Tags are key-value pairs that help you organize and categorize your resources.

Parameters:

tagResourceRequest -

Returns:

Result of the TagResource operation returned by the service.

See Also:

• AWS API Documentation

tagResource

default TagResourceResponse tagResource(Consumer<TagResourceRequest.Builder> tagResourceRequest)
                                 throws ThrottlingException,
ValidationException,
ResourceNotFoundException,
AccessDeniedException,
InternalServerException,
OperationTimeoutException,
AwsServiceException,
SdkClientException,
MwaaServerlessException

Adds tags to an Amazon Managed Workflows for Apache Airflow Serverless resource. Tags are key-value pairs that help you organize and categorize your resources.

This is a convenience which creates an instance of the TagResourceRequest.Builder avoiding the need to create one manually via TagResourceRequest.builder()

Parameters:

tagResourceRequest - A Consumer that will call methods on TagResourceRequest.Builder to create a request.

Returns:

Result of the TagResource operation returned by the service.

See Also:

• AWS API Documentation

untagResource

default UntagResourceResponse untagResource(UntagResourceRequest untagResourceRequest)
                                     throws ThrottlingException,
ValidationException,
ResourceNotFoundException,
AccessDeniedException,
InternalServerException,
OperationTimeoutException,
AwsServiceException,
SdkClientException,
MwaaServerlessException

Removes tags from an Amazon Managed Workflows for Apache Airflow Serverless resource. This operation removes the specified tags from the resource.

Parameters:

untagResourceRequest -

Returns:

Result of the UntagResource operation returned by the service.

See Also:

• AWS API Documentation

untagResource

default UntagResourceResponse untagResource(Consumer<UntagResourceRequest.Builder> untagResourceRequest)
                                     throws ThrottlingException,
ValidationException,
ResourceNotFoundException,
AccessDeniedException,
InternalServerException,
OperationTimeoutException,
AwsServiceException,
SdkClientException,
MwaaServerlessException

Removes tags from an Amazon Managed Workflows for Apache Airflow Serverless resource. This operation removes the specified tags from the resource.

This is a convenience which creates an instance of the UntagResourceRequest.Builder avoiding the need to create one manually via UntagResourceRequest.builder()

Parameters:

untagResourceRequest - A Consumer that will call methods on UntagResourceRequest.Builder to create a request.

Returns:

Result of the UntagResource operation returned by the service.

See Also:

• AWS API Documentation

updateWorkflow

default UpdateWorkflowResponse updateWorkflow(UpdateWorkflowRequest updateWorkflowRequest)
                                       throws ThrottlingException,
ValidationException,
ResourceNotFoundException,
AccessDeniedException,
InternalServerException,
OperationTimeoutException,
ConflictException,
ServiceQuotaExceededException,
AwsServiceException,
SdkClientException,
MwaaServerlessException

Updates an existing workflow with new configuration settings. This operation allows you to modify the workflow definition, role, and other settings. When you update a workflow, Amazon Managed Workflows for Apache Airflow Serverless automatically creates a new version with the updated configuration and disables scheduling on all previous versions to ensure only one version is actively scheduled at a time. The update operation maintains workflow history while providing a clean transition to the new configuration.

Parameters:

updateWorkflowRequest -

Returns:

Result of the UpdateWorkflow operation returned by the service.

See Also:

• AWS API Documentation

updateWorkflow

default UpdateWorkflowResponse updateWorkflow(Consumer<UpdateWorkflowRequest.Builder> updateWorkflowRequest)
                                       throws ThrottlingException,
ValidationException,
ResourceNotFoundException,
AccessDeniedException,
InternalServerException,
OperationTimeoutException,
ConflictException,
ServiceQuotaExceededException,
AwsServiceException,
SdkClientException,
MwaaServerlessException

Updates an existing workflow with new configuration settings. This operation allows you to modify the workflow definition, role, and other settings. When you update a workflow, Amazon Managed Workflows for Apache Airflow Serverless automatically creates a new version with the updated configuration and disables scheduling on all previous versions to ensure only one version is actively scheduled at a time. The update operation maintains workflow history while providing a clean transition to the new configuration.

This is a convenience which creates an instance of the UpdateWorkflowRequest.Builder avoiding the need to create one manually via UpdateWorkflowRequest.builder()

Parameters:

updateWorkflowRequest - A Consumer that will call methods on UpdateWorkflowRequest.Builder to create a request.

Returns:

Result of the UpdateWorkflow operation returned by the service.

See Also:

• AWS API Documentation

create

static MwaaServerlessClient create()

Create a MwaaServerlessClient with the region loaded from the DefaultAwsRegionProviderChain and credentials loaded from the DefaultCredentialsProvider.

builder

static MwaaServerlessClientBuilder builder()

Create a builder that can be used to configure and create a MwaaServerlessClient.

serviceMetadata

static ServiceMetadata serviceMetadata()

serviceClientConfiguration

default MwaaServerlessServiceClientConfiguration serviceClientConfiguration()

Description copied from interface: SdkClient

The SDK service client configuration exposes client settings to the user, e.g., ClientOverrideConfiguration

Specified by:

serviceClientConfiguration in interface AwsClient

Specified by:

serviceClientConfiguration in interface SdkClient

Returns:

SdkServiceClientConfiguration