cluster_get.py 文件源码

def execute(args: typing.NamedTuple):
    spark_client = load_spark_client()
    cluster_id = args.cluster_id
    cluster = spark_client.get_cluster(cluster_id)
    utils.print_cluster(spark_client, cluster)