We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 10a8a86 commit d5f71a9Copy full SHA for d5f71a9
scylla/tests/integration/shard_aware_batching.rs
@@ -150,14 +150,17 @@ async fn run_test(
150
)
151
});
152
153
+ // Take a global lock to make test deterministic
154
+ // (and because we need to push stuff in there to test that shard-awareness is respected)
155
+ let mut shards_for_nodes_test_check =
156
+ shards_for_nodes_test_check_clone.lock().await;
157
+
158
session
159
.batch(&scylla_batch, &batch)
160
.await
161
.expect("Query to send batch failed");
162
- shards_for_nodes_test_check_clone
- .lock()
- .await
163
+ shards_for_nodes_test_check
164
.entry(destination_shard.node_id)
165
.or_default()
166
.push(destination_shard.shard_id_on_node);
0 commit comments