Add check for nil timestamp

ansible · Oct 23, 2024 · d47c57e · d47c57e
1 parent ba214b9
commit d47c57e
Showing 1 changed file with 5 additions and 3 deletions.
diff --git a/pkg/workceptor/kubernetes.go b/pkg/workceptor/kubernetes.go
@@ -386,8 +386,11 @@ func (kw *KubeUnit) kubeLoggingWithReconnect(streamWait *sync.WaitGroup, stdout
 
 			split := strings.SplitN(line, " ", 2)
 			timeStamp := ParseTime(split[0])
-			if !timeStamp.After(sinceTime) && !successfulWrite {
-				continue
+			if timeStamp != nil {
+				if !timeStamp.After(sinceTime) && !successfulWrite {
+					continue
+				}
+				sinceTime = *timeStamp
 			}
 			msg := split[1]
 
@@ -399,7 +402,6 @@ func (kw *KubeUnit) kubeLoggingWithReconnect(streamWait *sync.WaitGroup, stdout
 				return
 			}
 			remainingRetries = retries // each time we read successfully, reset this counter
-			sinceTime = *timeStamp
 			successfulWrite = true
 		}