airflow.providers.amazon.aws.triggers.step_function

Module Contents

Classes

StepFunctionsExecutionCompleteTrigger

Trigger to poll for the completion of a Step Functions execution.
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.

hook()[source]

Override in subclasses to return the right hook.

Was this entry helpful?