airflow.providers.amazon.aws.triggers.neptune_analytics¶

Classes¶

`NeptuneGraphAvailableTrigger`	Triggers when a Neptune graph is available.
`NeptuneGraphPrivateEndpointAvailableTrigger`	Triggers when a Neptune Graph private endpoint is available.
`NeptuneGraphPrivateEndpointDeletedTrigger`	Triggers when a Neptune Graph private endpoint is deleted.
`NeptuneGraphDeletedTrigger`	Triggers when a Neptune Graph is deleted.
`NeptuneImportTaskCompleteTrigger`	Triggers when a Neptune import task successfully completes.
`NeptuneImportTaskCancelledTrigger`	Triggers when a Neptune import task is successfully cancelled.

Module Contents¶

class airflow.providers.amazon.aws.triggers.neptune_analytics.NeptuneGraphAvailableTrigger(*, graph_id, waiter_delay=30, waiter_max_attempts=60, **kwargs)[source]¶

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

Triggers when a Neptune graph is available.

Parameters:

graph_id (str) – Graph 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 – The Airflow connection used for AWS credentials.
region_name – AWS region name (example: us-east-1)

hook()[source]¶

Override in subclasses to return the right hook.

class airflow.providers.amazon.aws.triggers.neptune_analytics.NeptuneGraphPrivateEndpointAvailableTrigger(*, graph_id, vpc_id, waiter_delay=30, waiter_max_attempts=60, **kwargs)[source]¶

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

Triggers when a Neptune Graph private endpoint is available.

Parameters:

graph_id (str) – Graph Id waiting for the endpoint
vpc_id (str) – VPC id where endpoint is creating
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 – The Airflow connection used for AWS credentials.
region_name – AWS region name (example: us-east-1)

hook()[source]¶

Override in subclasses to return the right hook.

class airflow.providers.amazon.aws.triggers.neptune_analytics.NeptuneGraphPrivateEndpointDeletedTrigger(*, graph_id, vpc_id, endpoint_id, waiter_delay=30, waiter_max_attempts=60, **kwargs)[source]¶

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

Triggers when a Neptune Graph private endpoint is deleted.

Parameters:

graph_id (str) – Graph Id of the endpoint
vpc_id (str) – VPC id where endpoint resides
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 – The Airflow connection used for AWS credentials.
region_name – AWS region name (example: us-east-1)

hook()[source]¶

Override in subclasses to return the right hook.

class airflow.providers.amazon.aws.triggers.neptune_analytics.NeptuneGraphDeletedTrigger(*, graph_id, waiter_delay=30, waiter_max_attempts=60, **kwargs)[source]¶

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

Triggers when a Neptune Graph is deleted.

Parameters:

graph_id (str) – Graph Id to be deleted
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 – The Airflow connection used for AWS credentials.
region_name – AWS region name (example: us-east-1)

hook()[source]¶

Override in subclasses to return the right hook.

class airflow.providers.amazon.aws.triggers.neptune_analytics.NeptuneImportTaskCompleteTrigger(*, import_task_id, waiter_delay=30, waiter_max_attempts=60, **kwargs)[source]¶

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

Triggers when a Neptune import task successfully completes.

Parameters:

task_id – Import task id to monitor
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 – The Airflow connection used for AWS credentials.
region_name – AWS region name (example: us-east-1)

hook()[source]¶

Override in subclasses to return the right hook.

class airflow.providers.amazon.aws.triggers.neptune_analytics.NeptuneImportTaskCancelledTrigger(*, task_identifier, waiter_delay=30, waiter_max_attempts=60, **kwargs)[source]¶

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

Triggers when a Neptune import task is successfully cancelled.

Parameters:

task_id – Import task id to monitor.
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 – The Airflow connection used for AWS credentials.
region_name – AWS region name (example: us-east-1)

hook()[source]¶

Override in subclasses to return the right hook.