fix: use onInvalidSyntax properly when invalid flows

Author: François Delbrayelle

src/main/java/io/kestra/plugin/git/TenantSync.java

@@ -242,7 +242,7 @@ public Output run(RunContext runContext) throws Exception {
                 }
             }
 
-            List<FlowWithSource> kestraFlows = fetchFlowsFromKestra(kestraClient, runContext, namespace);
+            List<FlowWithSource> kestraFlows = fetchFlowsFromKestra(kestraClient, runContext, namespace, rOnInvalidSyntax);
             Map<String, byte[]> kestraFiles = listNamespaceFiles(kestraClient, runContext, namespace);
 
             planNamespace(
@@ -728,7 +728,7 @@ private void planDashboards(
         }
     }
 
-    private List<FlowWithSource> fetchFlowsFromKestra(KestraClient kestraClient, RunContext runContext, String namespace) {
+    private List<FlowWithSource> fetchFlowsFromKestra(KestraClient kestraClient, RunContext runContext, String namespace, OnInvalidSyntax rOnInvalidSyntax) {
         try {
             // Export all flows from Kestra for the given namespace (including sub-namespaces)
             byte[] zippedFlows = kestraClient.flows().exportFlowsByQuery(
@@ -748,9 +748,16 @@ private List<FlowWithSource> fetchFlowsFromKestra(KestraClient kestraClient, Run
                         continue;
                     }
 
-                    String yaml = new String(zis.readAllBytes(), StandardCharsets.UTF_8);
+                    var entryName = entry.getName();
+                    var yaml = new String(zis.readAllBytes(), StandardCharsets.UTF_8);
 
-                    io.kestra.core.models.flows.Flow parsed = io.kestra.core.serializers.YamlParser.parse(yaml, io.kestra.core.models.flows.Flow.class);
+                    io.kestra.core.models.flows.Flow parsed;
+                    try {
+                        parsed = io.kestra.core.serializers.YamlParser.parse(yaml, io.kestra.core.models.flows.Flow.class);
+                    } catch (Exception e) {
+                        handleInvalid(runContext, rOnInvalidSyntax, "FLOW from entry " + entryName, e);
+                        continue;
+                    }
 
                     if (!namespace.equals(parsed.getNamespace())) {
                         continue;
@@ -762,6 +769,9 @@ private List<FlowWithSource> fetchFlowsFromKestra(KestraClient kestraClient, Run
 
             return flows;
 
+        } catch (KestraRuntimeException e) {
+            // Re-throw KestraRuntimeException from handleInvalid(FAIL) without wrapping
+            throw e;
         } catch (Exception e) {
             throw new KestraRuntimeException("Failed to export flows from Kestra for namespace " + namespace, e);
         }