From afa52de11edc6b5b8911815d59c9be2127818739 Mon Sep 17 00:00:00 2001 From: Daniel Erenrich Date: Sun, 22 Jun 2025 10:11:59 -0700 Subject: [PATCH] handle the case where the date can't be parsed --- toolforge_weld/logs/kubernetes.py | 17 ++++++++++------- 1 file changed, 10 insertions(+), 7 deletions(-) diff --git a/toolforge_weld/logs/kubernetes.py b/toolforge_weld/logs/kubernetes.py index cef4e5e..59e8ec4 100644 --- a/toolforge_weld/logs/kubernetes.py +++ b/toolforge_weld/logs/kubernetes.py @@ -1,6 +1,6 @@ from typing import Dict, Iterator, Optional -from dateutil.parser import parse as parse_date +from dateutil.parser import parse as parse_date, ParserError from toolforge_weld.kubernetes import K8sClient from toolforge_weld.logs.source import LogEntry, LogSource @@ -39,12 +39,15 @@ class KubernetesSource(LogSource): timeout=None if follow else self.client.timeout, ): datetime, message = line.split(" ", 1) - yield LogEntry( - pod=pod_name, - container=container_name, - datetime=parse_date(datetime), - message=message, - ) + try: + yield LogEntry( + pod=pod_name, + container=container_name, + datetime=parse_date(datetime), + message=message, + ) + except ParserError: + pass def query( self, *, selector: Dict[str, str], follow: bool, lines: Optional[int] -- 2.44.0