airflow.providers.amazon.aws.triggers.comprehend

Module Contents

Classes

ComprehendPiiEntitiesDetectionJobCompletedTrigger

Trigger when a Comprehend pii entities detection job is complete.

ComprehendCreateDocumentClassifierCompletedTrigger

Trigger when a Comprehend document classifier is complete.

class airflow.providers.amazon.aws.triggers.comprehend.ComprehendPiiEntitiesDetectionJobCompletedTrigger(*, job_id, waiter_delay=120, waiter_max_attempts=75, aws_conn_id='aws_default')[source]

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

Trigger when a Comprehend pii entities detection job is complete.

Parameters
  • job_id (str) – The id of the Comprehend pii entities detection job.

  • waiter_delay (int) – The amount of time in seconds to wait between attempts. (default: 120)

  • waiter_max_attempts (int) – The maximum number of attempts to be made. (default: 75)

  • aws_conn_id (str | None) – The Airflow connection used for AWS credentials.

hook()[source]

Override in subclasses to return the right hook.

class airflow.providers.amazon.aws.triggers.comprehend.ComprehendCreateDocumentClassifierCompletedTrigger(*, document_classifier_arn, waiter_delay=120, waiter_max_attempts=75, aws_conn_id='aws_default')[source]

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

Trigger when a Comprehend document classifier is complete.

Parameters
  • document_classifier_arn (str) – The arn of the Comprehend document classifier.

  • waiter_delay (int) – The amount of time in seconds to wait between attempts. (default: 120)

  • waiter_max_attempts (int) – The maximum number of attempts to be made. (default: 75)

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