diff --git a/ccmlib/scylla_node.py b/ccmlib/scylla_node.py index 66e856db..52c40778 100644 --- a/ccmlib/scylla_node.py +++ b/ccmlib/scylla_node.py @@ -1251,6 +1251,12 @@ def upgrade(self, upgrade_to_version): def rollback(self, upgrade_to_version): self.upgrader.upgrade(upgrade_version=upgrade_to_version, recover_system_tables=True) + def wait_for_compactions(self, idle_timeout = None): + if idle_timeout is None: + idle_timeout = 300 if self.scylla_mode() != 'debug' else 900 + super(ScyllaNode, self).wait_for_compactions(idle_timeout=idle_timeout) + + class NodeUpgrader: """ @@ -1379,8 +1385,3 @@ def validate_version_after_upgrade(self): if self.node.node_scylla_version != expected_version: raise NodeUpgradeError("Node hasn't been upgraded. Expected version after upgrade: %s, Got: %s" % ( expected_version, self.node.node_scylla_version)) - - def wait_for_compactions(self, idle_timeout=None): - if idle_timeout is None: - idle_timeout = 300 if self.scylla_mode() != 'debug' else 900 - super(ScyllaNode, self).wait_for_compactions(idle_timeout=idle_timeout)