test: Fixed execution strategy

redis · Oct 9, 2024 · 348fee7 · 348fee7
1 parent 20e8196
commit 348fee7
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 2 deletions.
diff --git a/core/riot-core/src/main/java/com/redis/riot/core/AbstractJobCommand.java b/core/riot-core/src/main/java/com/redis/riot/core/AbstractJobCommand.java
@@ -141,9 +141,10 @@ private <I, O> TaskletStep step(Step<I, O> step) {
 		log.info("Creating {}", step);
 		SimpleStepBuilder<I, O> builder = simpleStep(step);
 		if (stepArgs.getRetryPolicy() == RetryPolicy.NEVER && stepArgs.getSkipPolicy() == SkipPolicy.NEVER) {
-			log.info("");
+			log.info("Skipping fault-tolerance for step {}", step.getName());
 			return builder.build();
 		}
+		log.info("Adding fault-tolerance to step {}", step.getName());
 		FaultTolerantStepBuilder<I, O> ftStep = JobUtils.faultTolerant(builder);
 		step.getSkip().forEach(ftStep::skip);
 		step.getNoSkip().forEach(ftStep::noSkip);

diff --git a/plugins/riot/src/test/java/com/redis/riot/AbstractRiotApplicationTestBase.java b/plugins/riot/src/test/java/com/redis/riot/AbstractRiotApplicationTestBase.java
@@ -57,7 +57,7 @@ protected int execute(ParseResult parseResult, IExecutionStrategy defaultStrateg
 			for (IExecutionStrategy config : configs) {
 				config.execute(parseResult);
 			}
-			return defaultStrategy.execute(parseResult);
+			return super.execute(parseResult, defaultStrategy);
 		}
 
 		private void configure(ParseResult parseResult) {