clusterspecgenerator_client.py 文件源码

def get_cluster_spec(self, application_id):
        request = csg.GetClusterSpecRequest()
        request.applicationId = application_id
        try:
            reply = self.stub.GetClusterSpec(request)
        except grpc.RpcError:
            return None
        return reply.clusterSpec