diff --git a/test/cluster-spec-sheet/mzcompose.py b/test/cluster-spec-sheet/mzcompose.py index 500aa80f1621c..88595a3744345 100644 --- a/test/cluster-spec-sheet/mzcompose.py +++ b/test/cluster-spec-sheet/mzcompose.py @@ -2521,7 +2521,9 @@ class Scenario(ABC): 3. `teardown(runner)` once. """ - VERSION: str = "1.0.0" + def version(self) -> str: + """Version recorded as ``scenario_version`` in result rows.""" + return "1.0.0" @abstractmethod def name(self) -> str: ... @@ -3165,6 +3167,9 @@ def __init__(self, name: str, workload: ClusterScalingScenario) -> None: self._name = name self._workload = workload + def version(self) -> str: + return self._workload.VERSION + def name(self) -> str: return self._name @@ -3203,6 +3208,9 @@ def __init__(self, name: str, workload: ClusterScalingScenario) -> None: self._workload = workload self._initial_scale = workload.scale + def version(self) -> str: + return self._workload.VERSION + def name(self) -> str: return self._name @@ -3256,6 +3264,9 @@ def __init__(self, name: str, workload: ClusterScalingScenario) -> None: self._workload = workload self._fixed_replica_size: str | None = None + def version(self) -> str: + return self._workload.VERSION + def name(self) -> str: return self._name @@ -3331,6 +3342,9 @@ def __init__( self._workload = workload self._sizes = sizes + def version(self) -> str: + return self._workload.VERSION + def name(self) -> str: return self._name @@ -4140,7 +4154,7 @@ def run_scenario( """ runner = ScenarioRunner( scenario.name(), - scenario.VERSION, + scenario.version(), 0, scenario.mode(), connection,