airflow.providers.amazon.aws.triggers.opensearch_serverless¶

Classes¶

OpenSearchServerlessCollectionActiveTrigger

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

Module Contents¶

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, region_name=None, verify=None, botocore_config=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.
region_name (str | None) – The AWS region where the collection is located.
verify (bool | str | None) – Whether to verify SSL certificates.
botocore_config (dict[str, Any] | None) – Configuration dictionary for the botocore client.

hook()[source]¶

Build the hook this trigger waits with.