diff --git a/krkn/scenario_plugins/node_actions/common_node_functions.py b/krkn/scenario_plugins/node_actions/common_node_functions.py index 43424f41..8b7ed576 100644 --- a/krkn/scenario_plugins/node_actions/common_node_functions.py +++ b/krkn/scenario_plugins/node_actions/common_node_functions.py @@ -1,16 +1,10 @@ -import datetime import time import random import logging import paramiko -from krkn_lib.models.k8s import AffectedNode -import krkn.invoke.command as runcommand from krkn_lib.k8s import KrknKubernetes -from krkn_lib.models.k8s import AffectedNode, AffectedNodeStatus from krkn_lib.models.k8s import AffectedNode -node_general = False - def get_node_by_name(node_name_list, kubecli: KrknKubernetes): killable_nodes = kubecli.list_killable_nodes() @@ -65,14 +59,6 @@ def wait_for_unknown_status(node, timeout, kubecli: KrknKubernetes, affected_nod return affected_node -# Get the ip of the cluster node -def get_node_ip(node): - return runcommand.invoke( - "kubectl get node %s -o " - "jsonpath='{.status.addresses[?(@.type==\"InternalIP\")].address}'" % (node) - ) - - def check_service_status(node, service, ssh_private_key, timeout): ssh = paramiko.SSHClient() ssh.set_missing_host_key_policy(paramiko.AutoAddPolicy())