taking out cerberus imports

Author: paigerube14

krkn/scenario_plugins/application_outage/application_outage_scenario_plugin.py

@@ -5,7 +5,6 @@
 from krkn_lib.telemetry.ocp import KrknTelemetryOpenshift
 from krkn_lib.utils import get_yaml_item_value, get_random_string
 from jinja2 import Template
-from krkn import cerberus
 from krkn.scenario_plugins.abstract_scenario_plugin import AbstractScenarioPlugin
 
 

krkn/scenario_plugins/container/container_scenario_plugin.py

@@ -9,7 +9,6 @@
 from krkn_lib.telemetry.ocp import KrknTelemetryOpenshift
 from krkn_lib.utils import get_yaml_item_value
 
-from krkn import cerberus
 from krkn.scenario_plugins.abstract_scenario_plugin import AbstractScenarioPlugin
 
 

krkn/scenario_plugins/network_chaos/network_chaos_scenario_plugin.py

@@ -10,7 +10,6 @@
 from krkn_lib.telemetry.ocp import KrknTelemetryOpenshift
 from krkn_lib.utils import get_yaml_item_value, log_exception
 
-from krkn import cerberus
 from krkn.scenario_plugins.node_actions import common_node_functions
 from krkn.scenario_plugins.abstract_scenario_plugin import AbstractScenarioPlugin
 
@@ -106,33 +105,21 @@ def run(
                                 return 1
                         if test_execution == "serial":
                             logging.info("Waiting for serial job to finish")
-                            start_time = int(time.time())
                             self.wait_for_job(
                                 joblst[:],
                                 lib_telemetry.get_lib_kubernetes(),
                                 test_duration + 300,
                             )
 
-                            end_time = int(time.time())
-                            cerberus.publish_kraken_status(
-                                None,
-                                start_time,
-                                end_time,
-                            )
                         if test_execution == "parallel":
                             break
                     if test_execution == "parallel":
                         logging.info("Waiting for parallel job to finish")
-                        start_time = int(time.time())
                         self.wait_for_job(
                             joblst[:],
                             lib_telemetry.get_lib_kubernetes(),
                             test_duration + 300,
                         )
-                        end_time = int(time.time())
-                        cerberus.publish_kraken_status(
-                            [], start_time, end_time
-                        )
                 except Exception as e:
                     logging.error(
                         "NetworkChaosScenarioPlugin exiting due to Exception %s" % e

krkn/scenario_plugins/service_disruption/service_disruption_scenario_plugin.py

@@ -8,7 +8,6 @@
 from krkn_lib.telemetry.ocp import KrknTelemetryOpenshift
 from krkn_lib.utils import get_yaml_item_value
 
-from krkn import cerberus
 from krkn.scenario_plugins.abstract_scenario_plugin import AbstractScenarioPlugin
 
 
@@ -58,8 +57,6 @@ def run(
                         + str(run_sleep)
                         + str(wait_time)
                     )
-                    logging.info("done")
-                    start_time = int(time.time())
                     for i in range(run_count):
                         killed_namespaces = {}
                         namespaces = (
@@ -113,10 +110,6 @@ def run(
                             )
                             time.sleep(run_sleep)
 
-                    end_time = int(time.time())
-                    cerberus.publish_kraken_status(
-                        [], start_time, end_time
-                    )
         except (Exception, RuntimeError) as e:
             logging.error(
                 "ServiceDisruptionScenarioPlugin exiting due to Exception %s" % e

krkn/scenario_plugins/zone_outage/zone_outage_scenario_plugin.py

@@ -12,7 +12,7 @@
 from krkn_lib.telemetry.ocp import KrknTelemetryOpenshift
 
 from krkn.scenario_plugins.abstract_scenario_plugin import AbstractScenarioPlugin
-from krkn.scenario_plugins.node_actions.aws_node_scenarios import AWS
+from krkn_lib.utils import get_yaml_item_value
 
 from krkn.scenario_plugins.node_actions.aws_node_scenarios import AWS
 from krkn.scenario_plugins.node_actions.gcp_node_scenarios import gcp_node_scenarios
@@ -30,7 +30,6 @@ def run(
                 zone_outage_config_yaml = yaml.full_load(f)
                 scenario_config = zone_outage_config_yaml["zone_outage"]
                 cloud_type = scenario_config["cloud_type"]
-                start_time = int(time.time())
                 if cloud_type.lower() == "aws":
                     self.cloud_object = AWS()
                     self.network_based_zone(scenario_config)
@@ -49,8 +48,6 @@ def run(
                         )
                         return 1
 
-                end_time = int(time.time())
-                cerberus.publish_kraken_status(krkn_config, [], start_time, end_time)
         except (RuntimeError, Exception) as e:
             logging.error(
                 f"ZoneOutageScenarioPlugin scenario {scenario} failed with exception: {e}"