TeradataComputeClusterProvisionOperator

The purpose of TeradataComputeClusterProvisionOperator is to provision the new Teradata Vantage Cloud Lake Compute Cluster with specified Compute Group Name and Compute Profile Name. Use the TeradataComputeClusterProvisionOperator to provision the new Compute Cluster in Teradata Vantage Cloud Lake.

An example usage of the TeradataComputeClusterProvisionOperator to provision the new Compute Cluster in Teradata Vantage Cloud Lake is as follows:

tests/system/teradata/example_teradata_compute_cluster.py[source]

    compute_cluster_provision_operation = TeradataComputeClusterProvisionOperator(
        task_id="compute_cluster_provision_operation",
        compute_profile_name="{{ params.compute_profile_name }}",
        compute_group_name="{{ params.compute_group_name }}",
        teradata_conn_id="{{ params.teradata_conn_id }}",
        timeout="{{ params.timeout }}",
        query_strategy="{{ params.query_strategy }}",
        compute_map="{{ params.compute_map }}",
        compute_attribute="{{ params.compute_attribute }}",
    )

TeradataComputeClusterDecommissionOperator

The purpose of TeradataComputeClusterDecommissionOperator is to decommission the specified Teradata Vantage Cloud Lake Compute Cluster. Use the TeradataComputeClusterProvisionOperator to decommission the specified Teradata Vantage Cloud Lake Compute Cluster.

An example usage of the TeradataComputeClusterDecommissionOperator to decommission the specified Teradata Vantage Cloud Lake Compute Cluster is as follows:

tests/system/teradata/example_teradata_compute_cluster.py[source]

    compute_cluster_decommission_operation = TeradataComputeClusterDecommissionOperator(
        task_id="compute_cluster_decommission_operation",
        compute_profile_name="{{ params.compute_profile_name }}",
        compute_group_name="{{ params.compute_group_name }}",
        delete_compute_group=bool("{{ params.delete_compute_group }}"),
        teradata_conn_id="{{ params.teradata_conn_id }}",
        timeout="{{ params.timeout }}",
    )

TeradataComputeClusterResumeOperator

The purpose of TeradataComputeClusterResumeOperator is to start the Teradata Vantage Cloud Lake Compute Cluster of specified Compute Group Name and Compute Profile Name. Use the TeradataComputeClusterResumeOperator to start the specified Compute Cluster in Teradata Vantage Cloud Lake.

An example usage of the TeradataComputeClusterSuspendOperator to start the specified Compute Cluster in Teradata Vantage Cloud Lake is as follows:

tests/system/teradata/example_teradata_compute_cluster.py[source]

    compute_cluster_resume_operation = TeradataComputeClusterResumeOperator(
        task_id="compute_cluster_resume_operation",
        compute_profile_name="{{ params.compute_profile_name }}",
        compute_group_name="{{ params.compute_group_name }}",
        teradata_conn_id="{{ params.teradata_conn_id }}",
        timeout="{{ params.timeout }}",
    )

TeradataComputeClusterSuspendOperator

The purpose of TeradataComputeClusterSuspendOperator is to suspend the Teradata Vantage Cloud Lake Compute Cluster of specified Compute Group Name and Compute Profile Name. Use the TeradataComputeClusterSuspendOperator to suspend the specified Compute Cluster in Teradata Vantage Cloud Lake.

An example usage of the TeradataComputeClusterSuspendOperator to suspend the specified Compute Cluster in Teradata Vantage Cloud Lake is as follows:

tests/system/teradata/example_teradata_compute_cluster.py[source]

    compute_cluster_suspend_operation = TeradataComputeClusterSuspendOperator(
        task_id="compute_cluster_suspend_operation",
        compute_profile_name="{{ params.compute_profile_name }}",
        compute_group_name="{{ params.compute_group_name }}",
        teradata_conn_id="{{ params.teradata_conn_id }}",
        timeout="{{ params.timeout }}",
    )

Was this entry helpful?