diff --git a/airbyte_cdk/sources/declarative/requesters/http_job_repository.py b/airbyte_cdk/sources/declarative/requesters/http_job_repository.py index 38339220..e6bd21ee 100644 --- a/airbyte_cdk/sources/declarative/requesters/http_job_repository.py +++ b/airbyte_cdk/sources/declarative/requesters/http_job_repository.py @@ -34,9 +34,6 @@ class AsyncHttpJobRepository(AsyncJobRepository): creation_requester: Requester polling_requester: Requester download_retriever: SimpleRetriever - url_requester: Optional[ - Requester - ] # use it in case polling_requester provides some and extra request is needed to obtain list of urls to download from abort_requester: Optional[Requester] delete_requester: Optional[Requester] status_extractor: DpathExtractor @@ -47,6 +44,9 @@ class AsyncHttpJobRepository(AsyncJobRepository): record_extractor: RecordExtractor = field( init=False, repr=False, default_factory=lambda: ResponseToFileExtractor({}) ) + url_requester: Optional[Requester] = ( + None # use it in case polling_requester provides some and extra request is needed to obtain list of urls to download from + ) def __post_init__(self) -> None: self._create_job_response_by_id: Dict[str, Response] = {}