This is an automated email from the ASF dual-hosted git repository. btellier pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/james-project.git
commit b671e3660643e7db8b0989b1e0aa7cb4b8218883 Author: Tung Tran <[email protected]> AuthorDate: Mon Aug 21 19:19:56 2023 +0700 Fix SessionWithInitializedTablesFactoryTest - updateVersion miss `.block` --- .../cassandra/init/SessionWithInitializedTablesFactoryTest.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/backends-common/cassandra/src/test/java/org/apache/james/backends/cassandra/init/SessionWithInitializedTablesFactoryTest.java b/backends-common/cassandra/src/test/java/org/apache/james/backends/cassandra/init/SessionWithInitializedTablesFactoryTest.java index 50425bfb76..6df654e066 100644 --- a/backends-common/cassandra/src/test/java/org/apache/james/backends/cassandra/init/SessionWithInitializedTablesFactoryTest.java +++ b/backends-common/cassandra/src/test/java/org/apache/james/backends/cassandra/init/SessionWithInitializedTablesFactoryTest.java @@ -99,7 +99,7 @@ class SessionWithInitializedTablesFactoryTest { .isEqualTo(MAX_VERSION); new CassandraTableManager(MODULE, session).clearTables(t -> true); - versionManagerDAO(session).updateVersion(MIN_VERSION); + versionManagerDAO(session).updateVersion(MIN_VERSION).block(); assertThat(versionManager(session).computeVersion().block()) .isEqualTo(MIN_VERSION); @@ -114,7 +114,7 @@ class SessionWithInitializedTablesFactoryTest { .isEqualTo(MAX_VERSION); new CassandraTableManager(MODULE, session).clearTables(t -> true); - versionManagerDAO(session).updateVersion(MIN_VERSION); + versionManagerDAO(session).updateVersion(MIN_VERSION).block(); assertThat(versionManager(session).computeVersion().block()) .isEqualTo(MIN_VERSION); session.execute(SchemaBuilder.dropTable(TABLE_NAME).build()); @@ -131,7 +131,7 @@ class SessionWithInitializedTablesFactoryTest { CqlSession cluster = ClusterFactory.create(clusterConfiguration, keyspaceConfiguration); KeyspaceFactory.createKeyspace(keyspaceConfiguration, cluster).block(); - return () -> new SessionWithInitializedTablesFactory( cluster, MODULE).get(); + return () -> new SessionWithInitializedTablesFactory(cluster, MODULE).get(); } private static void cleanCassandra(CqlSession session) { --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
