def getCluster(self):
    """Get the HDInsight cluster object"""

    # Get all the HDInsight clusters
    hdinsight_clusters = self.hdinsight_client.clusters.list()

    # Get current cluster
    for hdinsight_cluster in hdinsight_clusters:
        if hdinsight_cluster.name == self.params["CLUSTER_DNS_NAME"]:
            return hdinsight_cluster
    return None