From 5754078cf4b351be8b30b22d428d8986905e9ccf Mon Sep 17 00:00:00 2001 From: Mathieu Gabelle Date: Mon, 4 Nov 2024 13:41:26 +0100 Subject: [PATCH] fix(tests): fix tests --- src/main/java/io/kestra/plugin/redis/string/Set.java | 6 +++--- src/test/java/io/kestra/plugin/redis/PublishTest.java | 4 ++-- 2 files changed, 5 insertions(+), 5 deletions(-) diff --git a/src/main/java/io/kestra/plugin/redis/string/Set.java b/src/main/java/io/kestra/plugin/redis/string/Set.java index 7d139c1..9e99b1c 100644 --- a/src/main/java/io/kestra/plugin/redis/string/Set.java +++ b/src/main/java/io/kestra/plugin/redis/string/Set.java @@ -63,8 +63,7 @@ public class Set extends AbstractRedisConnection implements RunnableTask options = Property.of(Options.builder().build()); + private Property options; @Schema( title = "Define if you get the older value in response, does not work with Redis 5.X." @@ -84,7 +83,8 @@ public Output run(RunContext runContext) throws Exception { try (RedisFactory factory = this.redisFactory(runContext)) { String oldValue = factory.set( runContext.render(key).as(String.class).orElseThrow(), - runContext.render(serdeType).as(SerdeType.class).orElseThrow().serialize(runContext.render(value)), + runContext.render(serdeType).as(SerdeType.class).orElseThrow() + .serialize(runContext.render(value).as(String.class).orElseThrow()), runContext.render(get).as(Boolean.class).orElse(false), runContext.render(options).as(Options.class).orElse(Options.builder().build()).asRedisSet() ); diff --git a/src/test/java/io/kestra/plugin/redis/PublishTest.java b/src/test/java/io/kestra/plugin/redis/PublishTest.java index 0ffad63..4ec0898 100644 --- a/src/test/java/io/kestra/plugin/redis/PublishTest.java +++ b/src/test/java/io/kestra/plugin/redis/PublishTest.java @@ -44,7 +44,7 @@ void testPublishAsList() throws Exception { Publish task = Publish.builder() .url(Property.of(REDIS_URI)) .channel(Property.of("mych")) - .from(Property.of(Arrays.asList("value1", "value2"))) + .from(Arrays.asList("value1", "value2")) .build(); Publish.Output runOutput = task.run(runContext); @@ -61,7 +61,7 @@ void testPublishAsFile() throws Exception { Publish task = Publish.builder() .url(Property.of(REDIS_URI)) .channel(Property.of("mychFile")) - .from(Property.of(uri.toString())) + .from(uri.toString()) .build(); Publish.Output runOutput = task.run(runContext);