core/oc-monitord
6
0
Fork 0
Code Issues 2 Pull Requests Packages Projects Releases Wiki Activity

correct some comments/typo

Browse Source
This commit is contained in:
pb 2024-09-03 15:57:35 +02:00
parent ea44ca33b2
commit faf67c2dda
1 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
main.go
View File

@ -120,6 +120,8 @@ func getWorkflowId(exec_id string) string {
return wf_exec.WorkflowID return wf_exec.WorkflowID
} }
// So far we only log the output from
func executeWorkflow(argo_file_path string) { func executeWorkflow(argo_file_path string) {
// var stdout, stderr, stdout_logs, stderr_logs io.ReadCloser // var stdout, stderr, stdout_logs, stderr_logs io.ReadCloser
var stdout, stderr io.ReadCloser var stdout, stderr io.ReadCloser
@ -186,7 +188,7 @@ func logWorkflow(pipe io.ReadCloser, wg *sync.WaitGroup) {
// Debug, no logs sent // Debug, no logs sent
func logPods(pipe io.ReadCloser, name string) { func logPods(pipe io.ReadCloser, name string) {
pods_logger = wf_logger.With().Str("sortie name", name).Logger() pods_logger = wf_logger.With().Str("pod_name", name).Logger()
scanner := bufio.NewScanner(pipe) scanner := bufio.NewScanner(pipe)
for scanner.Scan() { for scanner.Scan() {
log := scanner.Text() log := scanner.Text()
@ -201,7 +203,7 @@ func loadConfig(is_k8s bool, parser *argparse.Parser) {
o = initOnion(o) o = initOnion(o)
// These variables can only be retrieved in the onion // These variables can only be retrieved in the onion
// Variables that don't depend on the environmen (from conf file), can be loaded after // Variables that don't depend on the environment (from conf file), can be loaded after
// We can't use underscore in the env variable names because it's the delimitor with OCMONITOR too // We can't use underscore in the env variable names because it's the delimitor with OCMONITOR too
setConf(is_k8s, o, parser) setConf(is_k8s, o, parser)