1
0
mirror of synced 2025-12-21 11:01:41 -05:00
Files
airbyte/airbyte-integrations/connectors/source-iterable/source_iterable/utils.py
2024-04-15 18:02:47 +02:00

27 lines
649 B
Python

#
# Copyright (c) 2023 Airbyte, Inc., all rights reserved.
#
import dateutil.parser
import pendulum
from airbyte_cdk.models import SyncMode
from airbyte_cdk.sources.streams import Stream
def dateutil_parse(text):
"""
The custom function `dateutil_parse` replace `pendulum.parse(text, strict=False)` to avoid memory leak.
More details https://github.com/airbytehq/airbyte/pull/19913
"""
dt = dateutil.parser.parse(text)
return pendulum.datetime(
dt.year,
dt.month,
dt.day,
dt.hour,
dt.minute,
dt.second,
dt.microsecond,
tz=dt.tzinfo or pendulum.tz.UTC,
)