weka · itzsimpl · May 4, 2025 · May 4, 2025
diff --git a/weka_upgrade_checker/weka_upgrade_checker.py b/weka_upgrade_checker/weka_upgrade_checker.py
@@ -1729,20 +1729,21 @@ def validate_core_ids(containers):
         printlist(override_list, 5)
 
     if V(weka_version) >= V("4.0"):
-    INFO("CHECKING FOR WEKA CLUSTER TASKS")
-    bg_task = []
-    cluster_tasks = json.loads(
-        subprocess.check_output(["weka", "cluster", "tasks", "-J"])
-    )
+        INFO("CHECKING FOR WEKA CLUSTER TASKS")
+        bg_task = []
+        cluster_tasks = json.loads(
+            subprocess.check_output(["weka", "cluster", "tasks", "-J"])
+        )
 
-    for task in cluster_tasks:
-        if task["type"] != "FSCK":
-            WARN("There are active cluster tasks that should be considered before running the upgrade.")
-            bg_task += [task["type"], task["description"]]
-            printlist(bg_task, 2)
-            break
-    else:
-        GOOD("No unexpected Weka cluster tasks running")
+        for task in cluster_tasks:
+            if task["type"] != "FSCK":
+                WARN("There are active cluster tasks that should be considered before running the upgrade.")
+                bg_task += [task["type"], task["description"]]
+                printlist(bg_task, 2)
+                break
+
+        if len(bg_task) == 0:
+            GOOD("No unexpected Weka cluster tasks running")
 
     INFO("CHECKING FOR WEKA BLACKLISTED NODES")
     blacklist = []
@@ -3606,7 +3607,7 @@ def backend_host_checks(
         INFO("VALIDATING CPU INSTRUCTION SET")
         results = parallel_execution(
             ssh_bk_hosts,
-            ['grep "\<avx2\>" /proc/cpuinfo'],
+            r['grep "\<avx2\>" /proc/cpuinfo'],
             use_check_output=True,
             ssh_identity=ssh_identity,
         )