CCP Job Scheduling Latency Benchmark

.yamllint

@@ -3,7 +3,6 @@
 # Default configuration: https://yamllint.readthedocs.io/en/stable/configuration.html#default-configuration
 
 extends: default
-
 rules:
   document-start: disable
   document-end: disable
@@ -20,3 +19,4 @@ rules:
 ignore: |
   modules/python/clusterloader2/**/*.yaml
   modules/python/clusterloader2/**/*.yml
+  scenarios/perf-eval/job-scheduler/**/*.yaml

modules/python/clients/kubernetes_client.py

@@ -3,16 +3,17 @@
 # https://kubernetes.io/docs/concepts/scheduling-eviction/taint-and-toleration/#taint-based-evictions
 # https://kubernetes.io/docs/reference/labels-annotations-taints/
 builtin_taints_keys = [
-	"node.kubernetes.io/not-ready",
-	"node.kubernetes.io/unreachable",
-	"node.kubernetes.io/pid-pressure",
-	"node.kubernetes.io/out-of-disk",
-	"node.kubernetes.io/memory-pressure",
-	"node.kubernetes.io/disk-pressure",
-	"node.kubernetes.io/network-unavailable",
-	"node.kubernetes.io/unschedulable",
-	"node.cloudprovider.kubernetes.io/uninitialized",
-	"node.cloudprovider.kubernetes.io/shutdown",
+    "node.kubernetes.io/not-ready",
+    "node.kubernetes.io/unreachable",
+    "node.kubernetes.io/pid-pressure",
+    "node.kubernetes.io/out-of-disk",
+    "node.kubernetes.io/memory-pressure",
+    "node.kubernetes.io/disk-pressure",
+    "node.kubernetes.io/network-unavailable",
+    "node.kubernetes.io/unschedulable",
+    "node.cloudprovider.kubernetes.io/uninitialized",
+    "node.cloudprovider.kubernetes.io/shutdown",
+    "kwok.x-k8s.io/kwok",
 ]
 
 class KubernetesClient:
@@ -46,15 +47,12 @@ def get_ready_nodes(self, label_selector=None, field_selector=None):
         ]
 
     def _is_node_schedulable(self, node):
-        is_schedulable = False
-        status_conditions = None
-        if node and node.status and node.status.conditions:
-            status_conditions = {cond.type: cond.status for cond in node.status.conditions}
-            is_schedulable = (
-                status_conditions.get("Ready") == "True" 
-                and status_conditions.get("NetworkUnavailable") != "True"
-                and node.spec.unschedulable is not True
-            )
+        status_conditions = {cond.type: cond.status for cond in node.status.conditions}
+        is_schedulable = (
+            status_conditions.get("Ready") == "True"
+            and status_conditions.get("NetworkUnavailable") != "True"
+            and node.spec.unschedulable is not True
+        )
         if not is_schedulable:
             print(f"Node NOT Ready: '{node.metadata.name}' is not schedulable. status_conditions: {status_conditions}. unschedulable: {node.spec.unschedulable}")