airflow.providers.amazon.aws.triggers.mwaa¶

类¶

MwaaDagRunCompletedTrigger

当 MWAA Dag Run 完成时触发。

模块内容¶

class airflow.providers.amazon.aws.triggers.mwaa.MwaaDagRunCompletedTrigger(*, external_env_name, external_dag_id, external_dag_run_id, success_states=None, failure_states=None, waiter_delay=60, waiter_max_attempts=720, aws_conn_id=None)[source]¶

基类: airflow.providers.amazon.aws.triggers.base.AwsBaseWaiterTrigger

当 MWAA Dag Run 完成时触发。

参数:

external_env_name (str) – 包含要等待的 DAG Run 的外部 MWAA 环境名称 (模板化)
external_dag_id (str) – 外部 MWAA 环境中包含要等待的 DAG Run 的 DAG ID (模板化)
external_dag_run_id (str) – 要等待的外部 MWAA 环境中的 DAG Run ID (模板化)
success_states (collections.abc.Collection[str] | None) – 使此任务标记为成功的 DAG Run 状态集合，默认为 {airflow.utils.state.DagRunState.SUCCESS} (模板化)
failure_states (collections.abc.Collection[str] | None) – 使此任务标记为失败并引发 AirflowException 的 DAG Run 状态集合，默认为 {airflow.utils.state.DagRunState.FAILED} (模板化)
waiter_delay (int) – 每次尝试之间等待的时间（秒）。 (默认: 60)
waiter_max_attempts (int) – 最大尝试次数。 (默认: 720)
aws_conn_id (str | None) – 用于 AWS 凭据的 Airflow 连接。

success_states[source]¶

failure_states[source]¶

hook()[source]¶

在子类中重写以返回正确的 hook。