From 10d26ba50e034fc65b52816af7d7f12b0fa3a6e6 Mon Sep 17 00:00:00 2001 From: Paige Patton Date: Wed, 11 Jun 2025 08:41:18 -0400 Subject: [PATCH] adding kube check into gcp zone' Signed-off-by: Paige Patton --- .../zone_outage/zone_outage_scenario_plugin.py | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/krkn/scenario_plugins/zone_outage/zone_outage_scenario_plugin.py b/krkn/scenario_plugins/zone_outage/zone_outage_scenario_plugin.py index 1146fe8f..3fea90c6 100644 --- a/krkn/scenario_plugins/zone_outage/zone_outage_scenario_plugin.py +++ b/krkn/scenario_plugins/zone_outage/zone_outage_scenario_plugin.py @@ -32,6 +32,7 @@ class ZoneOutageScenarioPlugin(AbstractScenarioPlugin): zone_outage_config_yaml = yaml.full_load(f) scenario_config = zone_outage_config_yaml["zone_outage"] cloud_type = scenario_config["cloud_type"] + kube_check = get_yaml_item_value(scenario_config, "kube_check", True) start_time = int(time.time()) if cloud_type.lower() == "aws": self.cloud_object = AWS() @@ -40,7 +41,7 @@ class ZoneOutageScenarioPlugin(AbstractScenarioPlugin): kubecli = lib_telemetry.get_lib_kubernetes() if cloud_type.lower() == "gcp": affected_nodes_status = AffectedNodeStatus() - self.cloud_object = gcp_node_scenarios(kubecli, affected_nodes_status) + self.cloud_object = gcp_node_scenarios(kubecli, kube_check, affected_nodes_status) self.node_based_zone(scenario_config, kubecli) affected_nodes_status = self.cloud_object.affected_nodes_status scenario_telemetry.affected_nodes.extend(affected_nodes_status.affected_nodes)