Skip to content

Commit 16440a3

Browse files
author
julien
committed
Fixed skipping
1 parent 8ea9005 commit 16440a3

File tree

7 files changed

+44
-19
lines changed

7 files changed

+44
-19
lines changed

build.gradle

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -79,4 +79,4 @@ subprojects {
7979
sourceCompatibility = 8
8080
targetCompatibility = 8
8181

82-
}
82+
}

subprojects/testcontainers-redis-junit/src/test/java/com/redis/testcontainers/junit/RedisModulesTests.java

Lines changed: 10 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -10,7 +10,6 @@
1010

1111
import com.redis.enterprise.Database;
1212
import com.redis.enterprise.RedisModule;
13-
import com.redis.lettucemod.api.sync.RedisModulesCommands;
1413
import com.redis.lettucemod.api.sync.RedisTimeSeriesCommands;
1514
import com.redis.lettucemod.search.Field;
1615
import com.redis.lettucemod.search.SearchResults;
@@ -34,16 +33,16 @@ protected Collection<RedisServer> redisServers() {
3433
.build()));
3534
}
3635

37-
@ParameterizedTest
38-
@RedisTestContextsSource
39-
void gearsPyExecute(RedisTestContext context) {
40-
RedisModulesCommands<String, String> sync = context.sync();
41-
sync.set("foo", "bar");
42-
String sleepPy = "def sleep(x):\n" + " from time import sleep\n" + " sleep(1)\n" + " return 1\n" + "\n"
43-
+ "GB().map(sleep).run()";
44-
Assertions.assertTrue(sync.pyexecute(sleepPy).getErrors().isEmpty());
45-
Assertions.assertTrue(sync.pyexecute("GB().run()").isOk());
46-
}
36+
// @ParameterizedTest
37+
// @RedisTestContextsSource
38+
// void gearsPyExecute(RedisTestContext context) {
39+
// RedisModulesCommands<String, String> sync = context.sync();
40+
// sync.set("foo", "bar");
41+
// String sleepPy = "def sleep(x):\n" + " from time import sleep\n" + " sleep(1)\n" + " return 1\n" + "\n"
42+
// + "GB().map(sleep).run()";
43+
// Assertions.assertTrue(sync.pyexecute(sleepPy).getErrors().isEmpty());
44+
// Assertions.assertTrue(sync.pyexecute("GB().run()").isOk());
45+
// }
4746

4847
@ParameterizedTest
4948
@RedisTestContextsSource

subprojects/testcontainers-redis/src/main/java/com/redis/testcontainers/AbstractRedisContainer.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -32,7 +32,7 @@ public String getRedisURI() {
3232

3333
@Override
3434
public String toString() {
35-
return ClassUtils.getShortClassName(getClass()) + " " + getRedisURI();
35+
return ClassUtils.getShortClassName(getClass()) + " active=" + isActive();
3636
}
3737

3838
}

subprojects/testcontainers-redis/src/main/java/com/redis/testcontainers/RedisClusterContainer.java

Lines changed: 10 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -2,12 +2,17 @@
22

33
import java.util.Objects;
44

5+
import org.slf4j.Logger;
6+
import org.slf4j.LoggerFactory;
57
import org.testcontainers.containers.GenericContainer;
68
import org.testcontainers.containers.wait.strategy.Wait;
9+
import org.testcontainers.shaded.org.apache.commons.lang.ClassUtils;
710
import org.testcontainers.utility.DockerImageName;
811

912
public class RedisClusterContainer extends GenericContainer<RedisClusterContainer> implements RedisServer {
1013

14+
private static final Logger log = LoggerFactory.getLogger(RedisClusterContainer.class);
15+
1116
public static final DockerImageName DEFAULT_IMAGE_NAME = DockerImageName.parse("grokzen/redis-cluster");
1217
public static final String DEFAULT_TAG = "6.2.1";
1318
public static final int DEFAULT_INITIAL_PORT = 7000;
@@ -111,7 +116,7 @@ public RedisClusterContainer withInitialPort(int port) {
111116

112117
@Override
113118
public String toString() {
114-
return "RedisClusterContainer " + getRedisURI();
119+
return ClassUtils.getShortClassName(getClass()) + " active=" + isActive();
115120
}
116121

117122
@Override
@@ -136,7 +141,10 @@ public boolean equals(Object obj) {
136141

137142
@Override
138143
public boolean isActive() {
139-
return System.getenv(ENV_SKIP_TESTS) == null;
144+
String skipValue = System.getenv(ENV_SKIP_TESTS);
145+
boolean active = !Boolean.parseBoolean(skipValue);
146+
log.info("Active: {} ({}='{}'}", active, ENV_SKIP_TESTS, skipValue);
147+
return active;
140148
}
141149

142150
}

subprojects/testcontainers-redis/src/main/java/com/redis/testcontainers/RedisContainer.java

Lines changed: 8 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,10 +1,14 @@
11
package com.redis.testcontainers;
22

3+
import org.slf4j.Logger;
4+
import org.slf4j.LoggerFactory;
35
import org.testcontainers.utility.DockerImageName;
46
import org.testcontainers.utility.MountableFile;
57

68
public class RedisContainer extends AbstractRedisContainer<RedisContainer> {
79

10+
private static final Logger log = LoggerFactory.getLogger(RedisContainer.class);
11+
812
public static final DockerImageName DEFAULT_IMAGE_NAME = DockerImageName.parse("redis");
913
public static final String DEFAULT_TAG = "6.2.6";
1014
public static final String ENV_SKIP_TESTS = "skipRedisTests";
@@ -44,7 +48,10 @@ public <C extends RedisContainer> C withKeyspaceNotifications() {
4448

4549
@Override
4650
public boolean isActive() {
47-
return System.getenv(ENV_SKIP_TESTS) == null;
51+
String skipValue = System.getenv(ENV_SKIP_TESTS);
52+
boolean active = !Boolean.parseBoolean(skipValue);
53+
log.info("Active: {} ({}='{}'}", active, ENV_SKIP_TESTS, skipValue);
54+
return active;
4855
}
4956

5057
}

subprojects/testcontainers-redis/src/main/java/com/redis/testcontainers/RedisEnterpriseContainer.java

Lines changed: 6 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -17,6 +17,7 @@
1717
import org.testcontainers.containers.output.OutputFrame;
1818
import org.testcontainers.containers.output.ToStringConsumer;
1919
import org.testcontainers.containers.wait.strategy.Wait;
20+
import org.testcontainers.shaded.org.apache.commons.lang.ClassUtils;
2021
import org.testcontainers.utility.DockerImageName;
2122
import org.testcontainers.utility.TestEnvironment;
2223

@@ -191,7 +192,7 @@ public boolean isCluster() {
191192

192193
@Override
193194
public String toString() {
194-
return "RedisEnterpriseContainer " + getRedisURI();
195+
return ClassUtils.getShortClassName(getClass()) + " active=" + isActive();
195196
}
196197

197198
private boolean isRunning(InspectContainerResponse containerInfo) {
@@ -224,7 +225,10 @@ public boolean equals(Object obj) {
224225

225226
@Override
226227
public boolean isActive() {
227-
return System.getenv(ENV_SKIP_TESTS) == null;
228+
String skipValue = System.getenv(ENV_SKIP_TESTS);
229+
boolean active = !Boolean.parseBoolean(skipValue);
230+
log.info("Active: {} ({}='{}'}", active, ENV_SKIP_TESTS, skipValue);
231+
return active;
228232
}
229233

230234
}

subprojects/testcontainers-redis/src/main/java/com/redis/testcontainers/RedisModulesContainer.java

Lines changed: 8 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,9 +1,13 @@
11
package com.redis.testcontainers;
22

3+
import org.slf4j.Logger;
4+
import org.slf4j.LoggerFactory;
35
import org.testcontainers.utility.DockerImageName;
46

57
public class RedisModulesContainer extends AbstractRedisContainer<RedisModulesContainer> {
68

9+
private static final Logger log = LoggerFactory.getLogger(RedisModulesContainer.class);
10+
711
public static final DockerImageName DEFAULT_IMAGE_NAME = DockerImageName.parse("redislabs/redismod");
812
public static final String DEFAULT_TAG = "latest";
913
public static final String ENV_SKIP_TESTS = "skipRedisModulesTests";
@@ -35,7 +39,10 @@ public boolean isCluster() {
3539

3640
@Override
3741
public boolean isActive() {
38-
return System.getenv(ENV_SKIP_TESTS) == null;
42+
String skipValue = System.getenv(ENV_SKIP_TESTS);
43+
boolean active = !Boolean.parseBoolean(skipValue);
44+
log.info("Active: {} ({}='{}'}", active, ENV_SKIP_TESTS, skipValue);
45+
return active;
3946
}
4047

4148
}

0 commit comments

Comments
 (0)