jprdonnelly/kestra
1
0
Fork 0
mirror of https://github.com/kestra-io/kestra.git synced 2025-12-19 18:05:41 -05:00
Code Issues Packages Projects Releases Wiki Activity

fix(tests): pass inputs() test

Browse Source
This commit is contained in:
mustafatarek
2025-12-07 01:10:13 +02:00
committed by Loïc Mathieu
parent 596a26a137
commit b3b2ef1b5a
3 changed files with 4 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
core/src/test/java/io/kestra/core/serializers/YamlParserTest.java
View File

@@ -123,9 +123,9 @@ class YamlParserTest {
Flow flow = this.parse("flows/valids/inputs.yaml");
assertThat(flow.getInputs().size()).isEqualTo(30);
assertThat(flow.getInputs().stream().filter(Input::getRequired).count()).isEqualTo(11L);
assertThat(flow.getInputs().stream().filter(Input::getRequired).count()).isEqualTo(12L);
assertThat(flow.getInputs().stream().filter(r -> !r.getRequired()).count()).isEqualTo(18L);
assertThat(flow.getInputs().stream().filter(r -> r.getDefaults() != null).count()).isEqualTo(3L);
assertThat(flow.getInputs().stream().filter(r -> r.getDefaults() != null).count()).isEqualTo(4L);
assertThat(flow.getInputs().stream().filter(r -> r instanceof StringInput stringInput && stringInput.getValidator() != null).count()).isEqualTo(1L);
}

1
core/src/test/java/io/kestra/plugin/core/flow/SubflowRunnerTest.java
View File

@@ -16,7 +16,6 @@ import org.junit.jupiter.api.Test;
import java.util.ArrayList;
import java.util.List;
import java.util.Map;
import java.util.concurrent.CountDownLatch;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.TimeoutException;

4
webserver/src/test/java/io/kestra/webserver/controllers/api/ExecutionControllerRunnerTest.java
View File

@@ -145,7 +145,7 @@ class ExecutionControllerRunnerTest {
.put("secret", "secret")
.put("array", "[1, 2, 3]")
.put("json", "{}")
.put("yaml", """
.put("yaml1", """
some: property
alist:
- of
@@ -760,7 +760,7 @@ class ExecutionControllerRunnerTest {
@LoadFlows({"flows/valids/inputs.yaml"})
void previewInternalStorageFileFromExecution() throws TimeoutException, QueueException{
Execution defaultExecution = runnerUtils.runOne(TENANT_ID, TESTS_FLOW_NS, "inputs", null, (flow, execution1) -> flowIO.readExecutionInputs(flow, execution1, inputs));
assertThat(defaultExecution.getTaskRunList()).hasSize(15);
assertThat(defaultExecution.getTaskRunList()).hasSize(15 );
String defaultPath = (String) defaultExecution.getInputs().get("file");