airflow.providers.amazon.aws.triggers.neptune¶

Classes¶

`NeptuneClusterAvailableTrigger`	Triggers when a Neptune Cluster is available.
`NeptuneClusterStoppedTrigger`	Triggers when a Neptune Cluster is stopped.
`NeptuneClusterInstancesAvailableTrigger`	Triggers when a Neptune Cluster Instance is available.

Module Contents¶

class airflow.providers.amazon.aws.triggers.neptune.NeptuneClusterAvailableTrigger(*, db_cluster_id, waiter_delay=30, waiter_max_attempts=60, aws_conn_id=None, region_name=None, **kwargs)[source]¶

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

Triggers when a Neptune Cluster is available.

Parameters:

db_cluster_id (str) – Cluster ID 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.
region_name (str | None) – AWS region name (example: us-east-1)

hook()[source]¶

Override in subclasses to return the right hook.

class airflow.providers.amazon.aws.triggers.neptune.NeptuneClusterStoppedTrigger(*, db_cluster_id, waiter_delay=30, waiter_max_attempts=60, aws_conn_id=None, region_name=None, **kwargs)[source]¶

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

Triggers when a Neptune Cluster is stopped.

Parameters:

db_cluster_id (str) – Cluster ID 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.
region_name (str | None) – AWS region name (example: us-east-1)

hook()[source]¶

Override in subclasses to return the right hook.

class airflow.providers.amazon.aws.triggers.neptune.NeptuneClusterInstancesAvailableTrigger(*, db_cluster_id, waiter_delay=30, waiter_max_attempts=60, aws_conn_id=None, region_name=None, **kwargs)[source]¶

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

Triggers when a Neptune Cluster Instance is available.

Parameters:

db_cluster_id (str) – Cluster ID to wait on instances from
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.
region_name (str | None) – AWS region name (example: us-east-1)

hook()[source]¶

Override in subclasses to return the right hook.