From c641e26af806755d2b0aba63b2be4db0f6659c70 Mon Sep 17 00:00:00 2001 From: Artem Inzhyyants Date: Fri, 10 Jan 2025 12:37:09 +0100 Subject: [PATCH] feat: ref Signed-off-by: Artem Inzhyyants --- .../sources/declarative/requesters/http_job_repository.py | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/airbyte_cdk/sources/declarative/requesters/http_job_repository.py b/airbyte_cdk/sources/declarative/requesters/http_job_repository.py index 383392208..e6bd21eeb 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] = {}