airflow.providers.amazon.aws.triggers.neptune

Module Contents

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.
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.

Was this entry helpful?