Reference ansible#1258: fix timestamp debug message

aeter · Jan 28, 2025 · 0cffbed · 0cffbed
1 parent af3e477
commit 0cffbed
Showing 1 changed file with 2 additions and 1 deletion.
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))