airflow.providers.amazon.aws.sensors.mwaa_serverless¶

Amazon MWAA Serverless sensors.

Classes¶

MwaaServerlessWorkflowRunSensor

Wait for an Amazon MWAA Serverless workflow run to reach a terminal state.

Module Contents¶

class airflow.providers.amazon.aws.sensors.mwaa_serverless.MwaaServerlessWorkflowRunSensor(*, workflow_arn, run_id, success_states=None, failure_states=None, **kwargs)[source]¶

Bases: airflow.providers.amazon.aws.sensors.base_aws.AwsBaseSensor[airflow.providers.amazon.aws.hooks.base_aws.AwsBaseHook]

Wait for an Amazon MWAA Serverless workflow run to reach a terminal state.

See also

For more information on how to use this sensor, take a look at the guide: Wait for a Workflow Run

Parameters:

workflow_arn (str) – The ARN of the workflow. (templated)
run_id (str) – The ID of the workflow run to monitor. (templated)
success_states (set[str] | None) – Set of states considered successful. Default: {"SUCCESS"}.
failure_states (set[str] | None) – Set of states that raise an exception. Default: {"FAILED", "TIMEOUT", "STOPPED"}.

aws_hook_class[source]¶

template_fields: tuple[str, Ellipsis][source]¶

workflow_arn[source]¶

run_id[source]¶

success_states[source]¶

failure_states[source]¶

poke(context)[source]¶

Override when deriving this class.