You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@cassandra.apache.org by ma...@apache.org on 2020/08/19 08:28:30 UTC

[cassandra-dtest] branch master updated: CASSANDRA-16039 - fixed tests for FQL (#90)

This is an automated email from the ASF dual-hosted git repository.

marcuse pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/cassandra-dtest.git


The following commit(s) were added to refs/heads/master by this push:
     new c449b8a  CASSANDRA-16039 - fixed tests for FQL (#90)
c449b8a is described below

commit c449b8a78aa06a6719537450bce674217bb2ebcd
Author: Štefan Miklošovič <st...@instaclustr.com>
AuthorDate: Wed Aug 19 10:28:24 2020 +0200

    CASSANDRA-16039 - fixed tests for FQL (#90)
---
 fqltool_test.py | 6 ++++--
 1 file changed, 4 insertions(+), 2 deletions(-)

diff --git a/fqltool_test.py b/fqltool_test.py
index f175e58..2625bb4 100644
--- a/fqltool_test.py
+++ b/fqltool_test.py
@@ -51,7 +51,7 @@ class TestFQLTool(Tester):
                 got_exception = True
             assert got_exception
             # replay the log files
-            self._run_fqltool_replay(node1, [tmpdir, tmpdir2], "127.0.0.1", None, None)
+            self._run_fqltool_replay(node1, [tmpdir, tmpdir2], "127.0.0.1", None, None, True)
             # and verify the data is there
             node1.stress(['read', 'n=1000'])
 
@@ -132,13 +132,15 @@ class TestFQLTool(Tester):
             output = self._run_fqltool_compare(node1, queries1, [results1, results2])
             assert b"MISMATCH" in output  # compares two different stress runs, should mismatch
 
-    def _run_fqltool_replay(self, node, logdirs, target, queries, results):
+    def _run_fqltool_replay(self, node, logdirs, target, queries, results, replay_ddl_statements=False):
         fqltool = self.fqltool(node)
         args = [fqltool, "replay", "--target {}".format(target)]
         if queries is not None:
             args.append("--store-queries {}".format(queries))
         if results is not None:
             args.append("--results {}".format(results))
+        if replay_ddl_statements is True:
+            args.append("--replay-ddl-statements")
         args.extend(logdirs)
         rc = subprocess.call(args)
         assert rc == 0


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@cassandra.apache.org
For additional commands, e-mail: commits-help@cassandra.apache.org