jprdonnelly/airbyte
1
0
Fork 0
mirror of synced 2025-12-23 21:03:15 -05:00
Code Issues Packages Projects Releases Wiki Activity

set default paginator (#14678)

Browse Source
This commit is contained in:
Alexandre Girard
2022-07-13 08:54:42 -07:00
committed by GitHub
parent 8dc558d496
commit a4c51cdc54
1 changed files with 2 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
airbyte-cdk/python/airbyte_cdk/sources/declarative/retrievers/simple_retriever.py
View File

@@ -7,6 +7,7 @@ from typing import Any, Iterable, List, Mapping, MutableMapping, Optional, Union
import requests
from airbyte_cdk.models import SyncMode
from airbyte_cdk.sources.declarative.extractors.http_selector import HttpSelector
from airbyte_cdk.sources.declarative.requesters.paginators.no_pagination import NoPagination
from airbyte_cdk.sources.declarative.requesters.paginators.paginator import Paginator
from airbyte_cdk.sources.declarative.requesters.requester import Requester
from airbyte_cdk.sources.declarative.retrievers.retriever import Retriever
@@ -30,7 +31,7 @@ class SimpleRetriever(Retriever, HttpStream):
):
self._name = name
self._primary_key = primary_key
self._paginator = paginator
self._paginator = paginator or NoPagination()
self._requester = requester
self._record_selector = record_selector
super().__init__(self._requester.get_authenticator())