airflow.providers.teradata.triggers.teradata_compute_cluster¶

類¶

TeradataComputeClusterSyncTrigger

獲取指定計算叢集的暫停或恢復操作的狀態。

模組內容¶

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]¶

基類：airflow.triggers.base.BaseTrigger

獲取指定計算叢集的暫停或恢復操作的狀態。

引數：:

teradata_conn_id (str) – 指向特定 Teradata 資料庫的 Teradata 連線 ID。
compute_profile_name (str) – 要管理的計算配置檔案的名稱。
compute_group_name (str | None) – 計算配置檔案所屬的計算組的名稱。
opr_type – 計算叢集操作 - 暫停/恢復
poll_interval (float | None) – 檢查狀態的輪詢間隔（分鐘）。

teradata_conn_id[source]¶

compute_profile_name[source]¶

compute_group_name = None[source]¶

operation_type = None[source]¶

poll_interval = None[source]¶

serialize()[source]¶

序列化 TeradataComputeClusterSyncTrigger 引數和 classpath。

async run()[source]¶

等待計算叢集操作完成。

async get_status()[source]¶

返回計算叢集的暫停/恢復操作狀態。