Skip to content

Commit 6e56e3a

Browse files
Don not shuffle replicas for LWT queries
1 parent 25d96a6 commit 6e56e3a

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

cassandra/policies.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -523,7 +523,7 @@ def make_query_plan(self, working_keyspace=None, query=None):
523523
else:
524524
replicas = self._cluster_metadata.get_replicas(keyspace, query.routing_key)
525525

526-
if self.shuffle_replicas:
526+
if self.shuffle_replicas and not query.is_lwt():
527527
shuffle(replicas)
528528

529529
def yield_in_order(hosts):

0 commit comments

Comments
 (0)