Make sure scenario version applies for source ingestion

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,