Merge pull request #523 from onepanelio/fix/workspace.core.ip

fix: update core pod host to use name instead of static value

Author: rushtehrani

pkg/workflow_execution.go

@@ -1555,17 +1555,8 @@ Will build a template that makes a CURL request to the onepanel-core API,
 with statistics about the workflow that was just executed.
 */
 func getCURLNodeTemplate(name, curlMethod, curlPath, curlBody string, inputs wfv1.Inputs) (template *wfv1.Template, err error) {
-	host := env.GetEnv("ONEPANEL_CORE_SERVICE_HOST", "onepanel-core.onepanel.svc.cluster.local")
-	if host == "" {
-		err = errors.New("ONEPANEL_CORE_SERVICE_HOST is empty.")
-		return
-	}
-	port := env.GetEnv("ONEPANEL_CORE_SERVICE_PORT", "80")
-	if port == "" {
-		err = errors.New("ONEPANEL_CORE_SERVICE_PORT is empty.")
-		return
-	}
-	endpoint := fmt.Sprintf("http://%s:%s%s", host, port, curlPath)
+	host := "onepanel-core.onepanel.svc.cluster.local"
+	endpoint := fmt.Sprintf("http://%s%s", host, curlPath)
 	template = &wfv1.Template{
 		Name:   name,
 		Inputs: inputs,

server/workspace_server.go

@@ -2,6 +2,7 @@ package server
 
 import (
 	"context"
+	"fmt"
 	"github.com/golang/protobuf/ptypes/empty"
 	"github.com/onepanelio/core/api"
 	v1 "github.com/onepanelio/core/pkg"
@@ -29,7 +30,7 @@ func apiWorkspace(wt *v1.Workspace, config v1.SystemConfig) *api.Workspace {
 		log.WithFields(log.Fields{
 			"Method": "apiWorkspace",
 			"Error":  "protocol is nil",
-		})
+		}).Error("apiWorkspace")
 
 		return nil
 	}
@@ -38,7 +39,7 @@ func apiWorkspace(wt *v1.Workspace, config v1.SystemConfig) *api.Workspace {
 		log.WithFields(log.Fields{
 			"Method": "apiWorkspace",
 			"Error":  "domain is nil",
-		})
+		}).Error("apiWorkspace")
 
 		return nil
 	}