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

返回计算集群的暂停/恢复操作状态。