1
0
mirror of synced 2025-12-21 11:01:41 -05:00

Source Github: fix caching for get_starting_point in stream "Commits" (#24398)

Signed-off-by: Sergey Chvalyuk <grubberr@gmail.com>
This commit is contained in:
Serhii Chvaliuk
2023-03-27 13:13:01 +03:00
committed by GitHub
parent 13ac15130d
commit 5053b278f5
9 changed files with 44 additions and 80 deletions

View File

@@ -7,11 +7,14 @@ from airbyte_cdk.models import SyncMode
from airbyte_cdk.sources.streams import Stream
def getter(D: dict, key_or_keys):
def getter(D: dict, key_or_keys, strict=True):
if not isinstance(key_or_keys, list):
key_or_keys = [key_or_keys]
for k in key_or_keys:
D = D[k]
if strict:
D = D[k]
else:
D = D.get(k, {})
return D