Skip to content

Commit

Permalink
Polishing.
Browse files Browse the repository at this point in the history
Reduce probability for flakiness.

See #1493.
  • Loading branch information
mp911de committed Aug 14, 2024
1 parent f6c1d7f commit 2b93618
Show file tree
Hide file tree
Showing 2 changed files with 4 additions and 3 deletions.
1 change: 0 additions & 1 deletion spring-data-cassandra-distribution/pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -38,7 +38,6 @@
</goals>
</execution>
</executions>

</plugin>

<plugin>
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -15,18 +15,20 @@
*/
package org.springframework.data.cassandra.observability;

import static org.assertj.core.api.Assertions.*;

import io.micrometer.core.instrument.MeterRegistry;
import io.micrometer.core.instrument.simple.SimpleMeterRegistry;
import io.micrometer.observation.Observation;
import io.micrometer.observation.ObservationRegistry;
import io.micrometer.observation.contextpropagation.ObservationThreadLocalAccessor;
import io.micrometer.tracing.test.SampleTestRunner;
import static org.assertj.core.api.Assertions.*;
import reactor.core.publisher.Mono;
import reactor.test.StepVerifier;
import reactor.util.context.Context;

import org.junit.jupiter.api.extension.ExtendWith;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.cassandra.ReactiveResultSet;
import org.springframework.data.cassandra.ReactiveSession;
Expand Down Expand Up @@ -88,7 +90,7 @@ public SampleTestRunnerConsumer yourCode() {

System.out.println(((SimpleMeterRegistry) meterRegistry).getMetersAsString());

assertThat(tracer.getFinishedSpans().size()).isGreaterThanOrEqualTo(7);
assertThat(tracer.getFinishedSpans()).hasSizeGreaterThanOrEqualTo(6);
};
}
}

0 comments on commit 2b93618

Please sign in to comment.