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

Classes¶

StepFunctionsExecutionCompleteTrigger

Trigger to poll for the completion of a Step Functions execution.

Module Contents¶

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)[source]¶

Bases: airflow.providers.amazon.aws.triggers.base.AwsBaseWaiterTrigger

Trigger to poll for the completion of a Step Functions execution.

Parameters:

execution_arn (str) – ARN of the state machine to poll
waiter_delay (int) – The amount of time in seconds to wait between attempts.
waiter_max_attempts (int) – The maximum number of attempts to be made.
aws_conn_id (str | None) – The Airflow connection used for AWS credentials.
region_name (str | None) – AWS region name to use. Override the region_name in connection (if provided).

hook()[source]¶

Override in subclasses to return the right hook.