airflow.providers.amazon.aws.triggers.step_function¶

类¶

StepFunctionsExecutionCompleteTrigger

用于轮询 Step Functions 执行完成的 Trigger。

模块内容¶

class airflow.providers.amazon.aws.triggers.step_function.StepFunctionsExecutionCompleteTrigger(*, execution_arn, waiter_delay=60, waiter_max_attempts=30, aws_conn_id=None, region_name=None, **kwargs)[源码]¶

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

用于轮询 Step Functions 执行完成的 Trigger。

参数:

execution_arn (str) – 要轮询的状态机的 ARN
waiter_delay (int) – 两次尝试之间等待的时间（秒）。
waiter_max_attempts (int) – 最大尝试次数。
aws_conn_id (str | None) – 用于 AWS 凭据的 Airflow 连接。

hook()[源码]¶

在子类中覆盖以返回正确的 hook。