fix location of file

dataplane-app · Mar 19, 2022 · b854fa3 · b854fa3
1 parent 69271ab
commit b854fa3
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 4 deletions.
diff --git a/app/mainapp/filesystem/file_create_processor.go b/app/mainapp/filesystem/file_create_processor.go
@@ -20,7 +20,7 @@ func FileCreateProcessor(nodeTypeDesc string, nodePath string, node models.Pipel
 print("Node id: ` + node.NodeID + `")`
 
 		// log.Println(content)
-		filepath = nodePath + "dp-entrypoint.py"
+		filepath = nodePath + "/dp-entrypoint.py"
 		err := os.WriteFile(filepath, []byte(content), 0644)
 		if err != nil {
 			return filepath, errors.New("Failed to write python file")

diff --git a/app/mainapp/filesystem/folder_node_add_update.go b/app/mainapp/filesystem/folder_node_add_update.go
@@ -80,7 +80,7 @@ func FolderNodeAddUpdate(pipelineID string, environmentID string) {
 				switch n.NodeTypeDesc {
 				// Python processor
 				case "python":
-					// log.Println("Node types:", n.NodeType, n.NodeTypeDesc)
+					// log.Println("Node types:", n.NodeType, n.NodeTypeDesc, config.CodeDirectory+rfolder)
 					path, err := FileCreateProcessor(n.NodeTypeDesc, config.CodeDirectory+rfolder, node)
 					if err != nil {
 						if config.Debug == "true" {

diff --git a/app/workers/runtask/runtask.go b/app/workers/runtask/runtask.go
@@ -155,8 +155,8 @@ func worker(ctx context.Context, msg modelmain.WorkerTaskSend) {
 		// Detect if folder is being requested
 		if strings.Contains(v, "${{nodedirectory}}") {
 
-			directoryRun := config.CodeDirectory + msg.Folder
-			// log.Println(config.CodeDirectory, directoryRun, msg.FolderID)
+			directoryRun := config.CodeDirectory + msg.Folder + "/"
+			// log.Println(directoryRun)
 
 			// construct the directory if the directory cant be found
 			if _, err := os.Stat(directoryRun); os.IsNotExist(err) {