Merge branch 'main' into api_resources

krkn-chaos · Nov 20, 2024 · c8436ed · c8436ed
2 parents 9eb9afb + 547f29b
commit c8436ed
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 2 deletions.
diff --git a/src/krkn_lib/k8s/krkn_kubernetes.py b/src/krkn_lib/k8s/krkn_kubernetes.py
@@ -1713,7 +1713,7 @@ def find_kraken_node(self) -> str:
         return node_name
 
     def watch_node_status(
-        self, node: str, status: str, timeout: int, resource_version: str
+        self, node: str, status: str, timeout: int
     ):
         """
         Watch for a specific node status
@@ -1728,7 +1728,6 @@ def watch_node_status(
             self.cli.list_node,
             field_selector=f"metadata.name={node}",
             timeout_seconds=timeout,
-            resource_version=f"{resource_version}",
         ):
             conditions = [
                 status

diff --git a/src/krkn_lib/models/elastic/models.py b/src/krkn_lib/models/elastic/models.py
@@ -126,6 +126,7 @@ class ElasticChaosRunTelemetry(Document):
     total_node_count = Integer()
     cloud_infrastructure = Text()
     cloud_type = Text()
+    cluster_version = Text()
     run_uuid = Text(fields={"keyword": Keyword()})
 
     class Index:
@@ -192,4 +193,6 @@ def __init__(
         self.total_node_count = chaos_run_telemetry.total_node_count
         self.cloud_infrastructure = chaos_run_telemetry.cloud_infrastructure
         self.cloud_type = chaos_run_telemetry.cloud_type
+        self.cluster_version = chaos_run_telemetry.cluster_version
         self.run_uuid = chaos_run_telemetry.run_uuid
+