airflow.providers.amazon.aws.triggers.opensearch_serverless

Module Contents

Classes

OpenSearchServerlessCollectionActiveTrigger

Trigger when an Amazon OpenSearch Serverless Collection reaches the ACTIVE state.
class airflow.providers.amazon.aws.triggers.opensearch_serverless.OpenSearchServerlessCollectionActiveTrigger(*, collection_id=None, collection_name=None, waiter_delay=60, waiter_max_attempts=20, aws_conn_id=None)[source]

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

Trigger when an Amazon OpenSearch Serverless Collection reaches the ACTIVE state.

Parameters

  • collection_id (str | None) – A collection ID. You can’t provide a name and an ID in the same request.

  • collection_name (str | None) – A collection name. You can’t provide a name and an ID in the same request.

  • waiter_delay (int) – The amount of time in seconds to wait between attempts. (default: 60)

  • waiter_max_attempts (int) – The maximum number of attempts to be made. (default: 20)

  • 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?