Merge pull request #107 from trickest/fix/execute-config

Fix YAML config node inputs
trickest · Jan 8, 2024 · e8729ee · e8729ee
2 parents 099bd41 + f53d9ff
commit e8729ee
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/cmd/execute/config.go b/cmd/execute/config.go
@@ -393,13 +393,13 @@ func addPrimitiveNodeFromConfig(wfVersion *types.WorkflowVersionDetailed, newPri
 			continue
 		}
 		isSplitter := strings.HasPrefix(node.Name, "file-splitter") || strings.HasPrefix(node.Name, "split-to-string")
-		if strings.HasSuffix(connection.Destination.ID, node.Name+"/"+paramName) ||
-			(isSplitter && strings.HasSuffix(connection.Destination.ID, node.Name+"/multiple/"+source)) ||
-			(node.Script != nil && (strings.HasSuffix(connection.Destination.ID,
+		if strings.Contains(connection.Destination.ID, node.Name+"/"+paramName) ||
+			(isSplitter && strings.Contains(connection.Destination.ID, node.Name+"/multiple/"+source)) ||
+			(node.Script != nil && (strings.Contains(connection.Destination.ID,
 				node.Name+"/"+strings.ToLower(newPNode.Type)+"/"+source))) {
 			connectionFound = true
 			primitiveNodeName := getNodeNameFromConnectionID(connection.Source.ID)
-			if strings.HasSuffix(connection.Destination.ID, node.Name+"/"+paramName) && newPNode.Name != primitiveNodeName {
+			if strings.Contains(connection.Destination.ID, node.Name+"/"+paramName) && newPNode.Name != primitiveNodeName {
 				// delete(wfVersion.Data.PrimitiveNodes, newPNode.Name)
 				pNode, ok := wfVersion.Data.PrimitiveNodes[primitiveNodeName]
 				if !ok {