Smaws_Client_MWAAServerless (smaws-clients.Smaws_Client

Types

module Types : sig ... end

Builders

val make_definition_s3_location : 
  ?version_id:Smaws_Lib.Smithy_api.Types.string_ ->
  object_key:Smaws_Lib.Smithy_api.Types.string_ ->
  bucket:Smaws_Lib.Smithy_api.Types.string_ ->
  unit ->
  Types.definition_s3_location

val make_schedule_configuration : 
  ?cron_expression:Smaws_Lib.Smithy_api.Types.string_ ->
  unit ->
  Types.schedule_configuration

val make_workflow_version_summary : 
  ?trigger_mode:Types.generic_string ->
  ?schedule_configuration:Types.schedule_configuration ->
  ?definition_s3_location:Types.definition_s3_location ->
  ?modified_at:Types.timestamp_value ->
  ?created_at:Types.timestamp_value ->
  ?is_latest_version:Types.is_latest_version ->
  workflow_arn:Types.workflow_arn ->
  workflow_version:Types.workflow_version ->
  unit ->
  Types.workflow_version_summary

val make_workflow_summary : 
  ?trigger_mode:Types.generic_string ->
  ?workflow_status:Types.workflow_status ->
  ?modified_at:Types.timestamp_value ->
  ?created_at:Types.timestamp_value ->
  ?description:Types.description_string ->
  ?name:Types.name_string ->
  ?workflow_version:Types.workflow_version ->
  workflow_arn:Types.workflow_arn ->
  unit ->
  Types.workflow_summary

val make_run_detail_summary : 
  ?ended_at:Types.timestamp_value ->
  ?started_at:Types.timestamp_value ->
  ?created_on:Types.timestamp_value ->
  ?status:Types.workflow_run_status ->
  unit ->
  Types.run_detail_summary

val make_workflow_run_summary : 
  ?run_detail_summary:Types.run_detail_summary ->
  ?run_type:Types.run_type ->
  ?workflow_version:Types.version_id ->
  ?workflow_arn:Types.workflow_arn ->
  ?run_id:Types.id_string ->
  unit ->
  Types.workflow_run_summary

val make_workflow_run_detail : 
  ?run_state:Types.workflow_run_status ->
  ?task_instances:Types.task_instance_ids ->
  ?error_message:Types.generic_string ->
  ?duration:Smaws_Lib.Smithy_api.Types.integer ->
  ?modified_at:Types.timestamp_value ->
  ?completed_on:Types.timestamp_value ->
  ?created_at:Types.timestamp_value ->
  ?started_on:Types.timestamp_value ->
  ?run_type:Types.run_type ->
  ?run_id:Types.id_string ->
  ?workflow_version:Types.version_id ->
  ?workflow_arn:Types.workflow_arn ->
  unit ->
  Types.workflow_run_detail

val make_validation_exception_field : 
  message:Types.error_message ->
  name:Smaws_Lib.Smithy_api.Types.string_ ->
  unit ->
  Types.validation_exception_field

val make_update_workflow_response : 
  ?warnings:Types.warning_messages ->
  ?workflow_version:Types.workflow_version ->
  ?modified_at:Types.timestamp_value ->
  workflow_arn:Types.workflow_arn ->
  unit ->
  Types.update_workflow_response

val make_logging_configuration : 
  log_group_name:Smaws_Lib.Smithy_api.Types.string_ ->
  unit ->
  Types.logging_configuration

val make_network_configuration : 
  ?subnet_ids:Types.subnet_ids ->
  ?security_group_ids:Types.security_group_ids ->
  unit ->
  Types.network_configuration

val make_update_workflow_request : 
  ?trigger_mode:Types.generic_string ->
  ?network_configuration:Types.network_configuration ->
  ?engine_version:Types.engine_version ->
  ?logging_configuration:Types.logging_configuration ->
  ?description:Types.description_string ->
  role_arn:Types.role_ar_n ->
  definition_s3_location:Types.definition_s3_location ->
  workflow_arn:Types.workflow_arn ->
  unit ->
  Types.update_workflow_request

val make_untag_resource_response : unit -> unit

val make_untag_resource_request : 
  tag_keys:Types.tag_keys ->
  resource_arn:Types.taggable_resource_arn ->
  unit ->
  Types.untag_resource_request

val make_task_instance_summary : 
  ?operator_name:Types.generic_string ->
  ?duration_in_seconds:Smaws_Lib.Smithy_api.Types.integer ->
  ?status:Types.task_instance_status ->
  ?task_instance_id:Types.id_string ->
  ?run_id:Types.id_string ->
  ?workflow_version:Types.version_id ->
  ?workflow_arn:Types.workflow_arn ->
  unit ->
  Types.task_instance_summary

val make_tag_resource_response : unit -> unit

val make_tag_resource_request : 
  tags:Types.tags ->
  resource_arn:Types.taggable_resource_arn ->
  unit ->
  Types.tag_resource_request

val make_stop_workflow_run_response : 
  ?status:Types.workflow_run_status ->
  ?run_id:Types.id_string ->
  ?workflow_version:Types.version_id ->
  ?workflow_arn:Types.workflow_arn ->
  unit ->
  Types.stop_workflow_run_response

val make_stop_workflow_run_request : 
  run_id:Types.id_string ->
  workflow_arn:Types.workflow_arn ->
  unit ->
  Types.stop_workflow_run_request

val make_start_workflow_run_response : 
  ?started_at:Types.timestamp_value ->
  ?status:Types.workflow_run_status ->
  ?run_id:Types.id_string ->
  unit ->
  Types.start_workflow_run_response

val make_start_workflow_run_request : 
  ?workflow_version:Types.version_id ->
  ?override_parameters:Types.object_map ->
  ?client_token:Types.idempotency_token_string ->
  workflow_arn:Types.workflow_arn ->
  unit ->
  Types.start_workflow_run_request

val make_list_workflows_response : 
  ?next_token:Smaws_Lib.Smithy_api.Types.string_ ->
  workflows:Types.workflow_summaries ->
  unit ->
  Types.list_workflows_response

val make_list_workflows_request : 
  ?next_token:Smaws_Lib.Smithy_api.Types.string_ ->
  ?max_results:Smaws_Lib.Smithy_api.Types.integer ->
  unit ->
  Types.list_workflows_request

val make_list_workflow_versions_response : 
  ?next_token:Smaws_Lib.Smithy_api.Types.string_ ->
  ?workflow_versions:Types.workflow_version_summaries ->
  unit ->
  Types.list_workflow_versions_response

val make_list_workflow_versions_request : 
  ?next_token:Smaws_Lib.Smithy_api.Types.string_ ->
  ?max_results:Smaws_Lib.Smithy_api.Types.integer ->
  workflow_arn:Types.workflow_arn ->
  unit ->
  Types.list_workflow_versions_request

val make_list_workflow_runs_response : 
  ?next_token:Smaws_Lib.Smithy_api.Types.string_ ->
  ?workflow_runs:Types.workflow_run_summaries ->
  unit ->
  Types.list_workflow_runs_response

val make_list_workflow_runs_request : 
  ?workflow_version:Types.version_id ->
  ?next_token:Smaws_Lib.Smithy_api.Types.string_ ->
  ?max_results:Smaws_Lib.Smithy_api.Types.integer ->
  workflow_arn:Types.workflow_arn ->
  unit ->
  Types.list_workflow_runs_request

val make_list_task_instances_response : 
  ?next_token:Smaws_Lib.Smithy_api.Types.string_ ->
  ?task_instances:Types.task_instance_summaries ->
  unit ->
  Types.list_task_instances_response

val make_list_task_instances_request : 
  ?next_token:Smaws_Lib.Smithy_api.Types.string_ ->
  ?max_results:Smaws_Lib.Smithy_api.Types.integer ->
  run_id:Types.id_string ->
  workflow_arn:Types.workflow_arn ->
  unit ->
  Types.list_task_instances_request

val make_list_tags_for_resource_response : 
  ?tags:Types.tags ->
  unit ->
  Types.list_tags_for_resource_response

val make_list_tags_for_resource_request : 
  resource_arn:Types.taggable_resource_arn ->
  unit ->
  Types.list_tags_for_resource_request

val make_get_workflow_run_response : 
  ?run_detail:Types.workflow_run_detail ->
  ?override_parameters:Types.object_map ->
  ?run_type:Types.run_type ->
  ?run_id:Types.id_string ->
  ?workflow_version:Types.version_id ->
  ?workflow_arn:Types.workflow_arn ->
  unit ->
  Types.get_workflow_run_response

val make_get_workflow_run_request : 
  run_id:Types.id_string ->
  workflow_arn:Types.workflow_arn ->
  unit ->
  Types.get_workflow_run_request

val make_encryption_configuration : 
  ?kms_key_id:Smaws_Lib.Smithy_api.Types.string_ ->
  type_:Types.encryption_type ->
  unit ->
  Types.encryption_configuration

val make_get_workflow_response : 
  ?workflow_definition:Types.generic_string ->
  ?trigger_mode:Types.generic_string ->
  ?network_configuration:Types.network_configuration ->
  ?role_arn:Types.role_ar_n ->
  ?schedule_configuration:Types.schedule_configuration ->
  ?definition_s3_location:Types.definition_s3_location ->
  ?workflow_status:Types.workflow_status ->
  ?engine_version:Types.engine_version ->
  ?logging_configuration:Types.logging_configuration ->
  ?encryption_configuration:Types.encryption_configuration ->
  ?modified_at:Types.timestamp_value ->
  ?created_at:Types.timestamp_value ->
  ?description:Types.description_string ->
  ?name:Types.name_string ->
  ?workflow_version:Types.workflow_version ->
  workflow_arn:Types.workflow_arn ->
  unit ->
  Types.get_workflow_response

val make_get_workflow_request : 
  ?workflow_version:Types.workflow_version ->
  workflow_arn:Types.workflow_arn ->
  unit ->
  Types.get_workflow_request

val make_get_task_instance_response : 
  ?xcom:Types.generic_map ->
  ?log_stream:Types.id_string ->
  ?task_id:Types.id_string ->
  ?error_message:Types.generic_string ->
  ?attempt_number:Smaws_Lib.Smithy_api.Types.integer ->
  ?started_at:Types.timestamp_value ->
  ?ended_at:Types.timestamp_value ->
  ?modified_at:Types.timestamp_value ->
  ?operator_name:Types.generic_string ->
  ?duration_in_seconds:Smaws_Lib.Smithy_api.Types.integer ->
  ?status:Types.task_instance_status ->
  ?workflow_version:Types.version_id ->
  task_instance_id:Types.id_string ->
  run_id:Types.id_string ->
  workflow_arn:Types.workflow_arn ->
  unit ->
  Types.get_task_instance_response

val make_get_task_instance_request : 
  run_id:Types.id_string ->
  task_instance_id:Types.id_string ->
  workflow_arn:Types.workflow_arn ->
  unit ->
  Types.get_task_instance_request

val make_delete_workflow_response : 
  ?workflow_version:Types.workflow_version ->
  workflow_arn:Types.workflow_arn ->
  unit ->
  Types.delete_workflow_response

val make_delete_workflow_request : 
  ?workflow_version:Types.workflow_version ->
  workflow_arn:Types.workflow_arn ->
  unit ->
  Types.delete_workflow_request

val make_create_workflow_response : 
  ?warnings:Types.warning_messages ->
  ?is_latest_version:Types.is_latest_version ->
  ?workflow_version:Types.workflow_version ->
  ?workflow_status:Types.workflow_status ->
  ?revision_id:Smaws_Lib.Smithy_api.Types.string_ ->
  ?created_at:Types.timestamp_value ->
  workflow_arn:Types.workflow_arn ->
  unit ->
  Types.create_workflow_response

val make_create_workflow_request : 
  ?trigger_mode:Types.generic_string ->
  ?tags:Types.tags ->
  ?network_configuration:Types.network_configuration ->
  ?engine_version:Types.engine_version ->
  ?logging_configuration:Types.logging_configuration ->
  ?encryption_configuration:Types.encryption_configuration ->
  ?description:Types.description_string ->
  ?client_token:Types.idempotency_token_string ->
  role_arn:Types.role_ar_n ->
  definition_s3_location:Types.definition_s3_location ->
  name:Types.name_string ->
  unit ->
  Types.create_workflow_request

Operations

module CreateWorkflow : sig ... end

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.

module DeleteWorkflow : sig ... end

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.

module GetTaskInstance : sig ... end

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.

module GetWorkflow : sig ... end

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

module GetWorkflowRun : sig ... end

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

module ListTagsForResource : sig ... end

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

module ListTaskInstances : sig ... end

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

module ListWorkflowRuns : sig ... end

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

module ListWorkflowVersions : sig ... end

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

module ListWorkflows : sig ... end

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.

module StartWorkflowRun : sig ... end

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.

module StopWorkflowRun : sig ... end

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.

module TagResource : sig ... end

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.

module UntagResource : sig ... end

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

module UpdateWorkflow : sig ... end

module Json_serializers : sig ... end

module Json_deserializers : sig ... end