fix crash on TimeParserException during preprocessing caused by inval… (#867)

Author: kaya-david

logprep/ng/abc/input.py

@@ -12,7 +12,7 @@
 from copy import deepcopy
 from functools import cached_property, partial
 from hmac import HMAC
-from typing import Literal, Optional, Self
+from typing import Optional, Self
 from zoneinfo import ZoneInfo
 
 from attrs import define, field, validators
@@ -26,7 +26,7 @@
 from logprep.ng.event.set_event_backlog import SetEventBacklog
 from logprep.processor.base.exceptions import FieldExistsWarning
 from logprep.util.helper import add_fields_to, get_dotted_field_value
-from logprep.util.time import UTC, TimeParser
+from logprep.util.time import UTC, TimeParser, TimeParserException
 from logprep.util.validators import dict_structure_validator
 
 
@@ -454,7 +454,7 @@ def get_next(self, timeout: float) -> LogEvent | None:
                     self._add_arrival_timedelta_information_to_event(event)
                 if self._add_env_enrichment:
                     self._add_env_enrichment_to_event(event)
-            except FieldExistsWarning as error:
+            except (FieldExistsWarning, TimeParserException) as error:
                 raise CriticalInputError(self, error.args[0], event) from error
         except CriticalInputError as error:
             self._register_failed_event(

logprep/ng/connector/confluent_kafka/input.py

@@ -32,7 +32,7 @@
 from functools import cached_property, partial
 from socket import getfqdn
 from types import MappingProxyType
-from typing import Any, Literal, Optional, Union
+from typing import Any, Optional, Union
 
 import msgspec
 from attrs import define, field, validators