(cluster: str, pool: str, scheduler: str)
Load the cluster connector for the given cluster and pool
Load the cluster connector for the given cluster and pool
Load the cluster connector for the given cluster and pool
def load(cluster: str, pool: str, scheduler: str) -> "ClusterConnector":
        """ Load the cluster connector for the given cluster and pool """
        if scheduler == "mesos":
            from clusterman.mesos.mesos_cluster_connector import MesosClusterConnector

            return MesosClusterConnector(cluster, pool)
        elif scheduler == "kubernetes":
            from clusterman.kubernetes.kubernetes_cluster_connector import KubernetesClusterConnector

            return KubernetesClusterConnector(cluster, pool)
        else:
            raise ValueError(f"Unknown scheduler type: {scheduler}")
def load ( cluster : str , pool : str , scheduler : str ) -> "ClusterConnector" : if scheduler == "mesos" : from clusterman . mesos . mesos_cluster_connector import MesosClusterConnector return MesosClusterConnector ( cluster , pool ) elif scheduler == "kubernetes" : from clusterman . kubernetes . kubernetes_cluster_connector import KubernetesClusterConnector return KubernetesClusterConnector ( cluster , pool ) else : raise ValueError ( f"Unknown scheduler type: {scheduler}" )