diff --git a/tap_zendesk/__init__.py b/tap_zendesk/__init__.py index b72ff88..434bc82 100755 --- a/tap_zendesk/__init__.py +++ b/tap_zendesk/__init__.py @@ -84,6 +84,7 @@ def get_abs_path(path): def get_side_load_schemas(sideload_objects, stream): + """Returns the updated schema after adding side load objects to schema dict""" stream_schema = stream.schema.to_dict() for sideload_object in sideload_objects: if sideload_object in SIDELOAD_OBJECTS[stream.tap_stream_id]: diff --git a/tap_zendesk/streams.py b/tap_zendesk/streams.py index c4aaa1a..847c523 100644 --- a/tap_zendesk/streams.py +++ b/tap_zendesk/streams.py @@ -29,6 +29,7 @@ DEFAULT_SEARCH_WINDOW_SIZE = (60 * 60 * 24) * 30 # defined in seconds, default to a month (30 days) def get_sideload_objects(stream): + """Returns the value of sideload-objects from metadata, returns None if no values are present""" return metadata.to_map(stream.metadata).get((), {}).get('sideload-objects') def get_abs_path(path):