Skip to content

Commit 48fd7ef

Browse files
committed
Handle database/dup
1 parent 043f4f9 commit 48fd7ef

File tree

2 files changed

+3
-6
lines changed

2 files changed

+3
-6
lines changed

instrumentation/cassandra/cassandra-4-common/testing/src/main/java/io/opentelemetry/cassandra/v4/common/AbstractCassandraTest.java

Lines changed: 2 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -108,8 +108,7 @@ void syncTest(Parameter parameter) {
108108
val.satisfiesAnyOf(
109109
v -> assertThat(v).isEqualTo("ipv4"),
110110
v -> assertThat(v).isEqualTo("ipv6"));
111-
}
112-
if (SemconvStability.emitStableDatabaseSemconv()) {
111+
} else {
113112
assertThat(val).isNull();
114113
}
115114
}),
@@ -176,8 +175,7 @@ void asyncTest(Parameter parameter) throws Exception {
176175
val.satisfiesAnyOf(
177176
v -> assertThat(v).isEqualTo("ipv4"),
178177
v -> assertThat(v).isEqualTo("ipv6"));
179-
}
180-
if (SemconvStability.emitStableDatabaseSemconv()) {
178+
} else {
181179
assertThat(val).isNull();
182180
}
183181
}),

instrumentation/cassandra/cassandra-4.4/testing/src/main/java/io/opentelemetry/testing/cassandra/v4_4/AbstractCassandra44Test.java

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -68,8 +68,7 @@ void reactiveTest(Parameter parameter) {
6868
val.satisfiesAnyOf(
6969
v -> assertThat(v).isEqualTo("ipv4"),
7070
v -> assertThat(v).isEqualTo("ipv6"));
71-
}
72-
if (SemconvStability.emitStableDatabaseSemconv()) {
71+
} else {
7372
assertThat(val).isNull();
7473
}
7574
}),

0 commit comments

Comments
 (0)