updated after the review

Author: Oleksandr Bazarnov

airbyte_cdk/sources/declarative/declarative_component_schema.yaml

@@ -3684,7 +3684,7 @@ interpolation:
       description: The `URL` received from the polling_requester in the AsyncRetriever with jobStatus as `COMPLETED`.
       type: string
       examples:
-        - url: "https://api.sendgrid.com/v3/marketing/lists?page_size=1&page_token=0236d6d2&filename=xxx_yyy_zzz.csv"
+        - "https://api.sendgrid.com/v3/marketing/lists?page_size=1&page_token=0236d6d2&filename=xxx_yyy_zzz.csv"
     - title: stream_interval
       description: The current stream interval being processed. The keys are defined by the incremental sync component. Default keys are `start_time` and `end_time`.
       type: object

airbyte_cdk/sources/declarative/requesters/http_job_repository.py

@@ -211,14 +211,14 @@ def fetch_records(self, job: AsyncJob) -> Iterable[Mapping[str, Any]]:
 
         """
 
-        for url in self._get_download_url(job):
+        for target_url in self._get_download_targets(job):
             job_slice = job.job_parameters()
             stream_slice = StreamSlice(
                 partition=job_slice.partition,
                 cursor_slice=job_slice.cursor_slice,
                 extra_fields={
                     **job_slice.extra_fields,
-                    "download_target": url,
+                    "download_target": target_url,
                 },
             )
             for message in self.download_retriever.read_records({}, stream_slice):
@@ -280,7 +280,7 @@ def _get_create_job_stream_slice(self, job: AsyncJob) -> StreamSlice:
         )
         return stream_slice
 
-    def _get_download_url(self, job: AsyncJob) -> Iterable[str]:
+    def _get_download_targets(self, job: AsyncJob) -> Iterable[str]:
         if not self.url_requester:
             url_response = self._polling_job_response_by_id[job.api_job_id()]
         else: