feat(system): add a boolean in the config to know if the concurrency view is enabled

Part-of: https://github.com/kestra-io/kestra-ee/issues/5882
This commit is contained in:
Loïc Mathieu
2025-12-11 14:26:53 +01:00
parent 687cefdfb9
commit eb12832b1e
2 changed files with 8 additions and 0 deletions

View File

@@ -100,6 +100,10 @@ private String chartDefaultDuration;
@io.micronaut.context.annotation.Value("${kestra.hidden-labels.prefixes:}")
private List<String> hiddenLabelsPrefixes;
@io.micronaut.context.annotation.Value("${kestra.queue.type}")
@Nullable
protected String queueType;
@Inject
private PluginRegistry pluginRegistry;
@@ -133,6 +137,7 @@ private String chartDefaultDuration;
.url(kestraUrl)
.pluginsHash(pluginRegistry.hash())
.chartDefaultDuration(this.chartDefaultDuration)
.isConcurrencyViewEnabled(!this.queueType.equals("kafka"))
;
if (this.environmentName != null || this.environmentColor != null) {
@@ -225,6 +230,8 @@ private String chartDefaultDuration;
Boolean isBasicAuthInitialized;
Long pluginsHash;
Boolean isConcurrencyViewEnabled;
}
@Value

View File

@@ -64,6 +64,7 @@ class MiscControllerTest {
assertThat(response.getIsAnonymousUsageEnabled()).isTrue();
assertThat(response.getIsAiEnabled()).isTrue();
assertThat(response.getSystemNamespace()).isEqualTo("some.system.ns");
assertThat(response.getIsConcurrencyViewEnabled()).isTrue();
}
@Test