Skip to content

Commit b410369

Browse files
committed
fix issues
1 parent af7d32c commit b410369

File tree

2 files changed

+4
-5
lines changed

2 files changed

+4
-5
lines changed

airbyte_cdk/sources/declarative/incremental/datetime_based_cursor.py

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -321,9 +321,7 @@ def parse_date(self, date: str) -> datetime.datetime:
321321
disallow_other_formats=False, # TODO: Consider permissive parsing.
322322
)
323323
except ValueError as ex:
324-
raise ValueError(
325-
f"No format in {formats} matching '{date}'"
326-
) from ex
324+
raise ValueError(f"No format in {formats} matching '{date}'") from ex
327325

328326
@classmethod
329327
def _parse_timedelta(cls, time_str: Optional[str]) -> Union[datetime.timedelta, Duration]:

airbyte_cdk/sources/file_based/stream/concurrent/cursor/file_based_concurrent_cursor.py

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -216,8 +216,9 @@ def _compute_latest_file_in_history(self) -> Optional[RemoteFile]:
216216
with self._state_lock:
217217
if self._file_to_datetime_history:
218218
filename, last_modified = max(
219-
self._file_to_datetime_history.items(), key=lambda f: (f[1], f[0])
220-
)``
219+
self._file_to_datetime_history.items(),
220+
key=lambda f: (f[1], f[0]),
221+
)
221222
return RemoteFile(
222223
uri=filename,
223224
last_modified=ab_datetime_parse(

0 commit comments

Comments
 (0)