Skip to content
Merged
Show file tree
Hide file tree
Changes from 1 commit
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
1 change: 1 addition & 0 deletions airbyte_cdk/sources/declarative/interpolation/macros.py
Original file line number Diff line number Diff line change
Expand Up @@ -177,6 +177,7 @@ def format_datetime(
dt_datetime = (
datetime.datetime.strptime(dt, input_format) if input_format else str_to_datetime(dt)
)
dt_datetime = dt_datetime.replace(tzinfo=pytz.utc)
return DatetimeParser().format(dt=dt_datetime, format=format)


Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -37,7 +37,7 @@ def get_json_schema(self) -> Mapping[str, Any]:

try:
return self.default_loader.get_json_schema()
except OSError:
except (OSError, ValueError):
# A slight hack since we don't directly have the stream name. However, when building the default filepath we assume the
# runtime options stores stream name 'name' so we'll do the same here
stream_name = self._parameters.get("name", "")
Expand Down
Loading