`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)[源代码]¶

基类： airflow.triggers.base.BaseTrigger

获取指定计算集群的暂停或恢复操作的状态。

参数

teradata_conn_id (str) – 指向特定 Teradata 数据库的 Teradata 连接 ID 引用。
compute_profile_name (str) – 要管理的计算配置文件的名称。
compute_group_name (str | None) – 计算配置文件所属的计算组的名称。
opr_type – 计算集群操作 - SUSPEND/RESUME（暂停/恢复）
poll_interval (float | None) – 检查状态的轮询间隔（分钟）

serialize()[源代码]¶

序列化 TeradataComputeClusterSyncTrigger 参数和类路径。

async run()[源代码]¶

等待计算集群操作完成。

async get_status()[源代码]¶

返回计算集群 SUSPEND/RESUME（暂停/恢复）操作状态。

airflow.providers.teradata.triggers.teradata_compute_cluster¶

模块内容¶

类¶

`airflow.providers.teradata.triggers.teradata_compute_cluster`¶