diff --git a/local-app/python-tools/gfl-resource-actions/aws_resource_management/managers/eks.py b/local-app/python-tools/gfl-resource-actions/aws_resource_management/managers/eks.py index c2fb8ed1..5d015d2d 100644 --- a/local-app/python-tools/gfl-resource-actions/aws_resource_management/managers/eks.py +++ b/local-app/python-tools/gfl-resource-actions/aws_resource_management/managers/eks.py @@ -111,7 +111,7 @@ def scale_down(self, clusters: List[Dict[str, Any]], dry_run: bool = False) -> N try: region = cluster["region"] - eks_client = self.create_client("eks", region) + eks_client = self.get_client("eks") # Get current scaling parameters from tags or nodegroups min_nodes = cluster.get("min_nodes", "") @@ -251,7 +251,7 @@ def scale_up(self, clusters: List[Dict[str, Any]], dry_run: bool = False) -> Non try: region = cluster["region"] - eks_client = self.create_client("eks", region) + eks_client = self.get_client("eks") # Check for original values in backup tags original_min = cluster.get("original_min", "") @@ -557,7 +557,8 @@ def discover_clusters(self, regions: List[str]) -> List[Dict[str, Any]]: for region in regions: try: - eks_client = self.create_client("eks", region) + self.region = region # Set region context for get_client + eks_client = self.get_client("eks") if not eks_client: logger.warning(f"Could not create EKS client in {region}") continue @@ -660,7 +661,8 @@ def _get_kubeconfig(self, cluster_name: str, region: str, account_id: str) -> st Returns path to the kubeconfig file. """ - eks = self.create_client("eks", region) + self.region = region # Set region context for get_client + eks = self.get_client("eks") cluster_info = eks.describe_cluster(name=cluster_name)["cluster"] # Use awscli to get token (assumes awscli is configured for this account) token = self._get_eks_token(cluster_name, region)