fix: unit test

This commit is contained in:
nKwiatkowski
2025-12-19 15:38:31 +01:00
parent 7a726c7bad
commit 3857d4a68f

View File

@@ -41,12 +41,6 @@ class FlowsSyncFromSourceCommandTest {
assertThat(out.toString()).contains("successfully updated !"); assertThat(out.toString()).contains("successfully updated !");
out.reset(); out.reset();
FlowRepositoryInterface repository = ctx.getBean(FlowRepositoryInterface.class);
List<Flow> flows = repository.findAll(MAIN_TENANT);
for (Flow flow : flows) {
assertThat(flow.getRevision()).isEqualTo(1);
}
args = new String[]{ args = new String[]{
"--plugins", "--plugins",
"/tmp", // pass this arg because it can cause failure "/tmp", // pass this arg because it can cause failure
@@ -63,11 +57,6 @@ class FlowsSyncFromSourceCommandTest {
assertThat(out.toString()).contains("- io.kestra.cli.second"); assertThat(out.toString()).contains("- io.kestra.cli.second");
assertThat(out.toString()).contains("- io.kestra.cli.third"); assertThat(out.toString()).contains("- io.kestra.cli.third");
assertThat(out.toString()).contains("- io.kestra.cli.first"); assertThat(out.toString()).contains("- io.kestra.cli.first");
flows = repository.findAll(MAIN_TENANT);
for (Flow flow : flows) {
assertThat(flow.getRevision()).isEqualTo(2);
}
} }
} }
} }