Reference ansible#1258: fix timestamp debug message

aeter · aeter · commit 5c5dc6b73d67 · 2025-01-28T09:24:40.000Z
Signed-off-by: Adrian Nackov &lt;adrian.nackov@mail.schwarz&gt;
diff --git a/pkg/workceptor/kubernetes.go b/pkg/workceptor/kubernetes.go
@@ -416,12 +416,13 @@ func (kw *KubeUnit) KubeLoggingWithReconnect(streamWait *sync.WaitGroup, stdout
 			msg := line
 			timestamp := ParseTime(split[0])
 			if timestamp != nil {
-				kw.GetWorkceptor().nc.GetLogger().Debug("No timestamp received, log line: '%s'", line)
 				if !timestamp.After(sinceTime) && !successfulWrite {
 					continue
 				}
 				sinceTime = *timestamp
 				msg = split[1]
+			} else {
+				kw.GetWorkceptor().nc.GetLogger().Debug("No timestamp received, log line: '%s'", line)
 			}
 
 			_, err = stdout.Write([]byte(msg))

Original file line number	Diff line number	Diff line change
`@@ -416,12 +416,13 @@ func (kw KubeUnit) KubeLoggingWithReconnect(streamWait sync.WaitGroup, stdout`
`416`	`416`	`msg := line`
`417`	`417`	`timestamp := ParseTime(split[0])`
`418`	`418`	`if timestamp != nil {`
`419`		`- kw.GetWorkceptor().nc.GetLogger().Debug("No timestamp received, log line: '%s'", line)`
`420`	`419`	`if !timestamp.After(sinceTime) && !successfulWrite {`
`421`	`420`	`continue`
`422`	`421`	`}`
`423`	`422`	`sinceTime = *timestamp`
`424`	`423`	`msg = split[1]`
	`424`	`+ } else {`
	`425`	`+ kw.GetWorkceptor().nc.GetLogger().Debug("No timestamp received, log line: '%s'", line)`
`425`	`426`	`}`
`426`	`427`
`427`	`428`	`_, err = stdout.Write([]byte(msg))`