Skip to content

Commit ac9c90d

Browse files
k0machifruch
authored andcommitted
fix(test_shard_aware.py): Use IN to check the thread name
This fixes an issue where thread name set by scylla would contain extra information, such as enterprise version containing current service level Fixes #228
1 parent b9035ba commit ac9c90d

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

tests/integration/standard/test_shard_aware.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -62,7 +62,7 @@ def verify_same_shard_in_tracing(self, results, shard_name):
6262
for event in events:
6363
LOGGER.info("%s %s %s", event.source, event.thread_name, event.description)
6464
for event in events:
65-
self.assertEqual(event.thread_name, shard_name)
65+
self.assertIn(shard_name, event.thread_name)
6666
self.assertIn('querying locally', "\n".join([event.description for event in events]))
6767

6868
trace_id = results.response_future.get_query_trace_ids()[0]
@@ -71,7 +71,7 @@ def verify_same_shard_in_tracing(self, results, shard_name):
7171
for event in events:
7272
LOGGER.info("%s %s", event.thread, event.activity)
7373
for event in events:
74-
self.assertEqual(event.thread, shard_name)
74+
self.assertIn(shard_name, event.thread)
7575
self.assertIn('querying locally', "\n".join([event.activity for event in events]))
7676

7777
def create_ks_and_cf(self):

0 commit comments

Comments
 (0)