Fix 'data-stream-stats' telemetry device version checks

elastic · Jun 21, 2023 · 944d78c · 944d78c
1 parent 7323e81
commit 944d78c
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/esrally/telemetry.py b/esrally/telemetry.py
@@ -1351,9 +1351,9 @@ def __init__(self, telemetry_params, clients, metrics_store):
     def on_benchmark_start(self):
         for cluster_name in self.specified_cluster_names:
             recorder = DataStreamStatsRecorder(cluster_name, self.clients[cluster_name], self.metrics_store, self.sample_interval)
-            client_info = self.clients[cluster_name].info()
-            distribution_version = client_info["version"]["number"]
-            distribution_flavor = client_info["version"].get("build_flavor", "oss")
+            es_info = self.clients[cluster_name].info()
+            distribution_version = es_info["version"].get("number", "7.9.0")
+            distribution_flavor = es_info["version"].get("build_flavor", "oss")
             if Version.from_string(distribution_version) < Version(major=7, minor=9, patch=0):
                 raise exceptions.SystemSetupError(
                     "The data-stream-stats telemetry device can only be used with clusters from version 7.9 onwards"