airflow.providers.teradata.triggers.teradata_compute_cluster

Module Contents

Classes

TeradataComputeClusterSyncTrigger

Fetch the status of the suspend or resume operation for the specified compute cluster.
class airflow.providers.teradata.triggers.teradata_compute_cluster.TeradataComputeClusterSyncTrigger(teradata_conn_id, compute_profile_name, compute_group_name=None, operation_type=None, poll_interval=None)[source]

Bases: airflow.triggers.base.BaseTrigger

Fetch the status of the suspend or resume operation for the specified compute cluster.

Parameters

  • teradata_conn_id (str) – The Teradata connection id reference to a specific Teradata database.

  • compute_profile_name (str) – Name of the Compute Profile to manage.

  • compute_group_name (str | None) – Name of compute group to which compute profile belongs.

  • opr_type – Compute cluster operation - SUSPEND/RESUME

  • poll_interval (float | None) – polling period in minutes to check for the status

serialize()[source]

Serialize TeradataComputeClusterSyncTrigger arguments and classpath.

async run()[source]

Wait for Compute Cluster operation to complete.

async get_status()[source]

Return compute cluster SUSPEND/RESUME operation status.

Was this entry helpful?