Skip to content

Commit

Permalink
Print telemetry data location to stdout
Browse files Browse the repository at this point in the history
This commit also deprecates litmus integration.
  • Loading branch information
chaitanyaenr committed Nov 13, 2023
1 parent dbf02a6 commit afe8d81
Show file tree
Hide file tree
Showing 2 changed files with 3 additions and 240 deletions.
221 changes: 0 additions & 221 deletions kraken/litmus/common_litmus.py

This file was deleted.

22 changes: 3 additions & 19 deletions run_kraken.py
Original file line number Diff line number Diff line change
Expand Up @@ -71,18 +71,6 @@ def main(cfg):
run_signal = get_yaml_item_value(
config["kraken"], "signal_state", "RUN"
)
litmus_install = get_yaml_item_value(
config["kraken"], "litmus_install", False
)
litmus_version = get_yaml_item_value(
config["kraken"], "litmus_version", "v1.9.1"
)
litmus_uninstall = get_yaml_item_value(
config["kraken"], "litmus_uninstall", True
)
litmus_uninstall_before_run = get_yaml_item_value(
config["kraken"], "litmus_uninstall_before_run", True
)
wait_duration = get_yaml_item_value(
config["tunings"], "wait_duration", 60
)
Expand Down Expand Up @@ -124,7 +112,8 @@ def main(cfg):
check_critical_alerts = get_yaml_item_value(
config["performance_monitoring"], "check_critical_alerts", False
)

telemetry_api_url = config["telemetry"].get("api_url")

# Initialize clients
if (not os.path.isfile(kubeconfig_path) and
not os.path.isfile("/var/run/secrets/kubernetes.io/serviceaccount/token")):
Expand Down Expand Up @@ -436,7 +425,7 @@ def main(cfg):
logging.info(f"Telemetry data:\n{decoded_chaos_run_telemetry.to_json()}")

if config["telemetry"]["enabled"]:
logging.info(f"telemetry data will be stored on s3 bucket folder: {telemetry_request_id}")
logging.info(f"telemetry data will be stored on s3 bucket folder: {telemetry_api_url}/download/{telemetry_request_id}")
logging.info(f"telemetry upload log: {safe_logger.log_file_name}")
try:
telemetry_k8s.send_telemetry(config["telemetry"], telemetry_request_id, chaos_telemetry)
Expand Down Expand Up @@ -489,11 +478,6 @@ def main(cfg):
logging.error("Alert profile is not defined")
sys.exit(1)

if litmus_uninstall and litmus_installed:
common_litmus.delete_chaos(litmus_namespace, kubecli)
common_litmus.delete_chaos_experiments(litmus_namespace, kubecli)
common_litmus.uninstall_litmus(litmus_version, litmus_namespace, kubecli)

if failed_post_scenarios:
logging.error(
"Post scenarios are still failing at the end of all iterations"
Expand Down

0 comments on commit afe8d81

Please sign in to comment.