Skip to content

Commit

Permalink
mark flaky tests
Browse files Browse the repository at this point in the history
Signed-off-by: Jan Jansen <[email protected]>
(cherry picked from commit 2e54144)
  • Loading branch information
farodin91 committed Jun 28, 2023
1 parent 263adca commit c98341e
Show file tree
Hide file tree
Showing 5 changed files with 34 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -15,6 +15,7 @@
package org.janusgraph.core.cql;

import com.datastax.driver.core.Session;
import io.github.artsok.RepeatedIfExceptionsTest;
import org.apache.commons.configuration2.MapConfiguration;
import org.janusgraph.JanusGraphCassandraContainer;
import org.janusgraph.core.AbstractConfiguredGraphFactoryTest;
Expand Down Expand Up @@ -130,5 +131,11 @@ public void dropGraphShouldRemoveGraphKeyspace() throws Exception {
ConfiguredGraphFactory.close(graphName);
}
}

@RepeatedIfExceptionsTest(repeats = 3)
@Override
public void updateConfigurationShouldRemoveGraphFromCache() throws Exception {
super.updateConfigurationShouldRemoveGraphFromCache();
}
}

Original file line number Diff line number Diff line change
Expand Up @@ -37,6 +37,7 @@

import java.util.Arrays;
import java.util.Random;
import java.util.concurrent.ExecutionException;
import java.util.stream.Stream;

import static org.janusgraph.diskstorage.cql.CQLConfigOptions.ATOMIC_BATCH_MUTATE;
Expand Down Expand Up @@ -70,6 +71,12 @@ public void simpleLogTest() throws InterruptedException{
super.simpleLogTest();
}

@RepeatedIfExceptionsTest(repeats = 3)
@Override
public void testReindexingForEdgeIndex() throws ExecutionException, InterruptedException {
super.testReindexingForEdgeIndex();
}

protected static Stream<Arguments> generateConsistencyConfigs() {
return Arrays.stream(new Arguments[]{
arguments(true, true, 20, true),
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -14,11 +14,15 @@

package org.janusgraph.hadoop;

import io.github.artsok.RepeatedIfExceptionsTest;
import org.janusgraph.JanusGraphCassandraContainer;
import org.janusgraph.diskstorage.BackendException;
import org.janusgraph.diskstorage.configuration.WriteConfiguration;
import org.testcontainers.junit.jupiter.Container;
import org.testcontainers.junit.jupiter.Testcontainers;

import java.util.concurrent.ExecutionException;

@Testcontainers
public class CQLIndexManagementIT extends AbstractIndexManagementIT {
@Container
Expand All @@ -28,4 +32,10 @@ public class CQLIndexManagementIT extends AbstractIndexManagementIT {
public WriteConfiguration getConfiguration() {
return cql.getConfiguration(getClass().getSimpleName().toLowerCase()).getConfiguration();
}

@RepeatedIfExceptionsTest(repeats = 3)
@Override
public void testRepairRelationIndex() throws ExecutionException, InterruptedException, BackendException {
super.testRepairRelationIndex();
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -14,12 +14,15 @@

package org.janusgraph.diskstorage.es;

import io.github.artsok.RepeatedIfExceptionsTest;
import org.janusgraph.JanusGraphCassandraContainer;
import org.janusgraph.diskstorage.configuration.ModifiableConfiguration;
import org.junit.jupiter.api.Disabled;
import org.testcontainers.junit.jupiter.Container;
import org.testcontainers.junit.jupiter.Testcontainers;

import java.util.concurrent.ExecutionException;

@Testcontainers
public class CQLElasticsearchTest extends ElasticsearchJanusGraphIndexTest {

Expand All @@ -34,4 +37,10 @@ public ModifiableConfiguration getStorageConfiguration() {
@Override
@Disabled("CQL seems to not clear storage correctly")
public void testClearStorage() {}

@RepeatedIfExceptionsTest(repeats = 3)
@Override
public void testIndexUpdatesWithoutReindex() throws InterruptedException, ExecutionException {
super.testIndexUpdatesWithoutReindex();
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -25,7 +25,6 @@
import org.janusgraph.diskstorage.keycolumnvalue.cache.ExpirationKCVSCache;
import org.janusgraph.diskstorage.keycolumnvalue.cache.KCVSCache;
import org.janusgraph.diskstorage.util.BufferUtil;
import org.junit.jupiter.api.Test;

import java.time.Duration;
import java.time.Instant;
Expand Down Expand Up @@ -97,7 +96,7 @@ private void testExpiration(Duration expirationTime) throws Exception {
verifyResults(key, keys, query, 4);
}

@Test
@RepeatedIfExceptionsTest(repeats = 3)
public void testGracePeriod() throws Exception {
testGracePeriod(Duration.ofMillis(200));
testGracePeriod(Duration.ZERO);
Expand Down

0 comments on commit c98341e

Please sign in to comment.