Fix do_upgrade in batch_test.py to upgrade to the current version
Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/557ab7b6 Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/557ab7b6 Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/557ab7b6 Branch: refs/heads/master Commit: 557ab7b6b7c62e341b3ec9c8e7041f7731a1c0bd Parents: d2d9e6d Author: Philip Thompson <ptnapol...@gmail.com> Authored: Wed Jul 5 11:40:30 2017 +0200 Committer: Philip Thompson <ptnapol...@gmail.com> Committed: Wed Jul 5 11:51:36 2017 +0200 ---------------------------------------------------------------------- batch_test.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/cassandra/blob/557ab7b6/batch_test.py ---------------------------------------------------------------------- diff --git a/batch_test.py b/batch_test.py index e67d185..4194f10 100644 --- a/batch_test.py +++ b/batch_test.py @@ -5,7 +5,7 @@ from unittest import skipIf from cassandra import ConsistencyLevel, Timeout, Unavailable from cassandra.query import SimpleStatement -from dtest import CASSANDRA_DIR, Tester, debug, create_ks +from dtest import Tester, create_ks, debug from tools.assertions import (assert_all, assert_invalid, assert_one, assert_unavailable) from tools.decorators import since @@ -433,7 +433,7 @@ class TestBatch(Tester): node.watch_log_for("DRAINED") node.stop(wait_other_notice=False) - node.set_install_dir(install_dir=CASSANDRA_DIR) + self.set_node_to_current_version(node) debug("Set new cassandra dir for {}: {}".format(node.name, node.get_install_dir())) # Restart nodes on new version --------------------------------------------------------------------- To unsubscribe, e-mail: commits-unsubscr...@cassandra.apache.org For additional commands, e-mail: commits-h...@cassandra.apache.org