Skip to content

Commit c343bcb

Browse files
committed
refactor: revert 3 changes per maintainer review to separate PRs
Per paigerube14 review on PR krkn-chaos#1208, move these changes to separate PRs for easier merge/test: - client.py: revert pod_type/pod_list variable rename back to k,v - network_chaos_ng_scenario_plugin.py: revert instance_count condition order - HealthChecker.py: revert current_iterations/ret_value back to class-level attrs
1 parent 33efbef commit c343bcb

File tree

3 files changed

+18
-15
lines changed

3 files changed

+18
-15
lines changed

krkn/prometheus/client.py

Lines changed: 12 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -261,37 +261,37 @@ def metrics(
261261
pass
262262
telemetry_json = json.loads(telemetry_json)
263263
for scenario in telemetry_json['scenarios']:
264-
for pod_type, pod_list in scenario["affected_pods"].items():
264+
for k,v in scenario["affected_pods"].items():
265265
metric_name = "affected_pods_recovery"
266-
metric = {"metricName": metric_name, "type": pod_type}
267-
if type(pod_list) is list:
268-
for pod in pod_list:
269-
for pod_k, pod_v in pod.items():
270-
metric[pod_k] = pod_v
266+
metric = {"metricName": metric_name, "type": k}
267+
if type(v) is list:
268+
for pod in v:
269+
for k,v in pod.items():
270+
metric[k] = v
271271
metric['timestamp'] = str(datetime.datetime.now())
272272
logging.debug("adding pod %s", metric)
273273
metrics_list.append(metric.copy())
274274
for affected_node in scenario["affected_nodes"]:
275275
metric_name = "affected_nodes_recovery"
276276
metric = {"metricName": metric_name}
277-
for node_k, node_v in affected_node.items():
278-
metric[node_k] = node_v
277+
for k,v in affected_node.items():
278+
metric[k] = v
279279
metric['timestamp'] = str(datetime.datetime.now())
280280
metrics_list.append(metric.copy())
281281
if telemetry_json['health_checks']:
282282
for health_check in telemetry_json["health_checks"]:
283283
metric_name = "health_check_recovery"
284284
metric = {"metricName": metric_name}
285-
for hc_k, hc_v in health_check.items():
286-
metric[hc_k] = hc_v
285+
for k,v in health_check.items():
286+
metric[k] = v
287287
metric['timestamp'] = str(datetime.datetime.now())
288288
metrics_list.append(metric.copy())
289289
if telemetry_json['virt_checks']:
290290
for virt_check in telemetry_json["virt_checks"]:
291291
metric_name = "virt_check_recovery"
292292
metric = {"metricName": metric_name}
293-
for vc_k, vc_v in virt_check.items():
294-
metric[vc_k] = vc_v
293+
for k,v in virt_check.items():
294+
metric[k] = v
295295
metric['timestamp'] = str(datetime.datetime.now())
296296
metrics_list.append(metric.copy())
297297

krkn/scenario_plugins/network_chaos_ng/network_chaos_ng_scenario_plugin.py

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -67,7 +67,10 @@ def run(
6767
f"with target type {network_chaos_type}"
6868
)
6969

70-
if network_chaos_config.instance_count != 0 and len(targets) > network_chaos_config.instance_count:
70+
if (
71+
network_chaos_config.instance_count != 0
72+
and network_chaos_config.instance_count > len(targets)
73+
):
7174
targets = random.sample(
7275
targets, network_chaos_config.instance_count
7376
)

krkn/utils/HealthChecker.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -22,10 +22,10 @@
2222
from krkn_lib.models.telemetry.models import HealthCheck
2323

2424
class HealthChecker:
25+
current_iterations: int = 0
26+
ret_value = 0
2527
def __init__(self, iterations):
2628
self.iterations = iterations
27-
self.current_iterations: int = 0
28-
self.ret_value = 0
2929

3030
def make_request(self, url, auth=None, headers=None, verify=True):
3131
response_data = {}

0 commit comments

Comments
 (0)