airflow.providers.amazon.aws.triggers.kinesis_analytics
¶
Module Contents¶
Classes¶
Trigger when a Managed Service for Apache Flink application Start or Stop is complete. |
- class airflow.providers.amazon.aws.triggers.kinesis_analytics.KinesisAnalyticsV2ApplicationOperationCompleteTrigger(application_name, waiter_name, waiter_delay=120, waiter_max_attempts=75, aws_conn_id='aws_default', **kwargs)[source]¶
Bases:
airflow.providers.amazon.aws.triggers.base.AwsBaseWaiterTrigger
Trigger when a Managed Service for Apache Flink application Start or Stop is complete.
- Parameters
application_name (str) – Application name.
waiter_name (str) – The name of the waiter for stop or start application.
waiter_delay (int) – The amount of time in seconds to wait between attempts. (default: 120)
waiter_max_attempts (int) – The maximum number of attempts to be made. (default: 75)
aws_conn_id (str | None) – The Airflow connection used for AWS credentials.