Skip to content

Commit 1c886fd

Browse files
committed
test_shard_aware: Copy values from Java driver.
Use shard values (keys, shard number) from Java driver tests. Java driver uses values compatible with smp=2, so with those values we'll be able to run those tests in CI (it has only 2 cores).
1 parent dca3ab7 commit 1c886fd

File tree

1 file changed

+7
-7
lines changed

1 file changed

+7
-7
lines changed

tests/integration/standard/test_shard_aware.py

Lines changed: 7 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -38,7 +38,7 @@
3838

3939

4040
def setup_module():
41-
os.environ['SCYLLA_EXT_OPTS'] = "--smp 4 --memory 2048M"
41+
os.environ['SCYLLA_EXT_OPTS'] = "--smp 2"
4242
use_cluster('shard_aware', [3], start=True)
4343

4444

@@ -109,7 +109,7 @@ def create_data(session):
109109
session.execute(bound)
110110
bound = prepared.bind(('e', 'f', 'g'))
111111
session.execute(bound)
112-
bound = prepared.bind(('100000', 'f', 'g'))
112+
bound = prepared.bind(('100002', 'f', 'g'))
113113
session.execute(bound)
114114

115115
def query_data(self, session, verify_in_tracing=True):
@@ -122,20 +122,20 @@ def query_data(self, session, verify_in_tracing=True):
122122
results = session.execute(bound, trace=True)
123123
self.assertEqual(results, [('a', 'b', 'c')])
124124
if verify_in_tracing:
125-
self.verify_same_shard_in_tracing(results, "shard 1")
125+
self.verify_same_shard_in_tracing(results, "shard 0")
126126

127-
bound = prepared.bind(('100000', 'f'))
127+
bound = prepared.bind(('100002', 'f'))
128128
results = session.execute(bound, trace=True)
129-
self.assertEqual(results, [('100000', 'f', 'g')])
129+
self.assertEqual(results, [('100002', 'f', 'g')])
130130

131131
if verify_in_tracing:
132-
self.verify_same_shard_in_tracing(results, "shard 0")
132+
self.verify_same_shard_in_tracing(results, "shard 1")
133133

134134
bound = prepared.bind(('e', 'f'))
135135
results = session.execute(bound, trace=True)
136136

137137
if verify_in_tracing:
138-
self.verify_same_shard_in_tracing(results, "shard 1")
138+
self.verify_same_shard_in_tracing(results, "shard 0")
139139

140140
def test_all_tracing_coming_one_shard(self):
141141
"""

0 commit comments

Comments
 (0)