fix(core): make flow repository an optional bean

kestra-io · Aug 5, 2024 · 0cc8ada · 0cc8ada
1 parent 4e7298a
commit 0cc8ada
Showing 1 changed file with 8 additions and 5 deletions.
diff --git a/core/src/main/java/io/kestra/core/services/NamespaceService.java b/core/src/main/java/io/kestra/core/services/NamespaceService.java
@@ -6,14 +6,15 @@
 
 import java.util.List;
 import java.util.Objects;
+import java.util.Optional;
 
 @Singleton
 public class NamespaceService {
 
-    private final FlowRepositoryInterface flowRepository;
+    private final Optional<FlowRepositoryInterface> flowRepository;
 
     @Inject
-    public NamespaceService(FlowRepositoryInterface flowRepository) {
+    public NamespaceService(Optional<FlowRepositoryInterface> flowRepository) {
         this.flowRepository = flowRepository;
     }
 
@@ -27,8 +28,10 @@ public NamespaceService(FlowRepositoryInterface flowRepository) {
     public boolean isNamespaceExists(String tenant, String namespace) {
         Objects.requireNonNull(namespace, "namespace cannot be null");
 
-        List<String> namespaces =  flowRepository.findDistinctNamespace(tenant);
-        return namespaces.stream().anyMatch(ns -> ns.equals(namespace));
+        if (flowRepository.isPresent()) {
+            List<String> namespaces = flowRepository.get().findDistinctNamespace(tenant);
+            return namespaces.stream().anyMatch(ns -> ns.equals(namespace));
+        }
+        return false;
     }
-
 }