airflow.providers.amazon.aws.triggers.athena

Module Contents

Classes

AthenaTrigger

Trigger for AthenaOperator.
class airflow.providers.amazon.aws.triggers.athena.AthenaTrigger(query_execution_id, waiter_delay, waiter_max_attempts, aws_conn_id, **kwargs)[source]

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

Trigger for AthenaOperator.

The trigger will asynchronously poll the boto3 API and wait for the Redshift cluster to be in the available state.

Parameters

  • query_execution_id (str) – ID of the Athena query execution to watch

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