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 d4b05a4 commit 6102876Copy full SHA for 6102876
google-cloud-spanner/src/test/java/com/google/cloud/spanner/it/ITAsyncExamplesTest.java
@@ -305,6 +305,12 @@ public void runAsyncBatchUpdate() throws Exception {
305
},
306
executor);
307
assertThat(insertCount.get()).asList().containsExactly(1L, 1L, 1L);
308
+ if (env.getTestHelper().getOptions().getSessionPoolOptions().getUseMultiplexedSessionForRW()) {
309
+ // The runAsync() method should only be called once on the runner.
310
+ // However, due to a bug in regular sessions, it can be executed multiple times on the same
311
+ // runner.
312
+ runner = client.runAsync();
313
+ }
314
ApiFuture<long[]> deleteCount =
315
runner.runAsync(
316
txn ->
0 commit comments