fix(core): fix FileWatcher loading flow from local file

kestra-io · Oct 23, 2024 · d3ccf4f · d3ccf4f
1 parent 9162353
commit d3ccf4f
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/cli/src/main/java/io/kestra/cli/services/FileChangedEventListener.java b/cli/src/main/java/io/kestra/cli/services/FileChangedEventListener.java
@@ -121,7 +121,7 @@ public void startListening(List<Path> paths) throws IOException, InterruptedExce
                 WatchEvent.Kind<?> kind = watchEvent.kind();
                 Path entry = (Path) watchEvent.context();
 
-                if (entry.endsWith(".yml") || entry.endsWith(".yaml")) {
+                if (entry.toString().endsWith(".yml") || entry.toString().endsWith(".yaml")) {
 
                     if (kind == StandardWatchEventKinds.ENTRY_CREATE || kind == StandardWatchEventKinds.ENTRY_MODIFY) {
 

diff --git a/cli/src/main/java/io/kestra/cli/services/LocalFlowFileWatcher.java b/cli/src/main/java/io/kestra/cli/services/LocalFlowFileWatcher.java
@@ -23,12 +23,12 @@ public FlowWithSource createOrUpdateFlow(Flow flow, String content) {
 
     public void deleteFlow(FlowWithSource toDelete) {
         flowRepositoryInterface.findByIdWithSource(toDelete.getTenantId(), toDelete.getNamespace(), toDelete.getId()).ifPresent(flowRepositoryInterface::delete);
-        log.debug("Flow {} has been deleted", toDelete.getId());
+        log.error("Flow {} has been deleted", toDelete.getId());
     }
 
     @Override
     public void deleteFlow(String tenantId, String namespace, String id) {
         flowRepositoryInterface.findByIdWithSource(tenantId, namespace, id).ifPresent(flowRepositoryInterface::delete);
-        log.debug("Flow {} has been deleted", id);
+        log.error("Flow {} has been deleted", id);
     }
 }