From 2e17c6b3ab64f4649871feaad04f2fc16f108dfa Mon Sep 17 00:00:00 2001 From: Henry Hughes Date: Tue, 7 Nov 2023 11:21:07 -0800 Subject: [PATCH] JAVA-3107: use slow-profile during initialization of DefaultReactiveResultSetIT --- .../core/cql/reactive/DefaultReactiveResultSetIT.java | 8 ++++++-- 1 file changed, 6 insertions(+), 2 deletions(-) diff --git a/integration-tests/src/test/java/com/datastax/oss/driver/core/cql/reactive/DefaultReactiveResultSetIT.java b/integration-tests/src/test/java/com/datastax/oss/driver/core/cql/reactive/DefaultReactiveResultSetIT.java index cfb6a56fac..3af5bc434f 100644 --- a/integration-tests/src/test/java/com/datastax/oss/driver/core/cql/reactive/DefaultReactiveResultSetIT.java +++ b/integration-tests/src/test/java/com/datastax/oss/driver/core/cql/reactive/DefaultReactiveResultSetIT.java @@ -64,8 +64,12 @@ public class DefaultReactiveResultSetIT { @BeforeClass public static void initialize() { CqlSession session = sessionRule.session(); - session.execute("DROP TABLE IF EXISTS test_reactive_read"); - session.execute("DROP TABLE IF EXISTS test_reactive_write"); + session.execute( + SimpleStatement.newInstance("DROP TABLE IF EXISTS test_reactive_read") + .setExecutionProfile(sessionRule.slowProfile())); + session.execute( + SimpleStatement.newInstance("DROP TABLE IF EXISTS test_reactive_write") + .setExecutionProfile(sessionRule.slowProfile())); session.checkSchemaAgreement(); session.execute( SimpleStatement.builder(