Skip to content

Commit a56f079

Browse files
committed
fix tests
1 parent 5801629 commit a56f079

File tree

2 files changed

+2
-1
lines changed

2 files changed

+2
-1
lines changed

‎airbyte_cdk/sources/declarative/interpolation/macros.py

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -177,6 +177,7 @@ def format_datetime(
177177
dt_datetime = (
178178
datetime.datetime.strptime(dt, input_format) if input_format else str_to_datetime(dt)
179179
)
180+
dt_datetime = dt_datetime.replace(tzinfo=pytz.utc)
180181
return DatetimeParser().format(dt=dt_datetime, format=format)
181182

182183

‎airbyte_cdk/sources/declarative/schema/default_schema_loader.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -37,7 +37,7 @@ def get_json_schema(self) -> Mapping[str, Any]:
3737

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

0 commit comments

Comments
 (0)