fix error

This commit is contained in:
rushtehrani
2020-01-09 16:47:58 -08:00
parent d124e587c1
commit 4da9e79a2d

View File

@@ -139,7 +139,7 @@ func (r *ResourceManager) GetWorkflowLogs(namespace, name, podName, containerNam
stream, err := r.kubeClient.GetPodLogs(namespace, podName, containerName)
logWatcher := make(chan *model.LogEntry)
if err != nil {
if err == nil {
go func() {
scanner := bufio.NewScanner(stream)
for scanner.Scan() {