Skip to content

Commit 0f62848

Browse files
author
Oleksandr Bazarnov
committed
fixed missing interpolation context for certain sources
1 parent 18e636c commit 0f62848

File tree

1 file changed

+4
-4
lines changed

1 file changed

+4
-4
lines changed

airbyte_cdk/sources/declarative/requesters/http_job_repository.py

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -283,14 +283,14 @@ def _get_creation_response_interpolation_context(self, job: AsyncJob) -> Dict[st
283283
Returns:
284284
Dict[str, Any]: The interpolation context as a dictionary.
285285
"""
286-
creation_response_context = self._create_job_response_by_id[job.api_job_id()].json()
286+
creation_response_context = dict(self._create_job_response_by_id[job.api_job_id()].json())
287287
creation_response_context["headers"] = self._create_job_response_by_id[
288288
job.api_job_id()
289289
].headers
290290
creation_response_context["request"] = self._create_job_response_by_id[
291291
job.api_job_id()
292292
].request
293-
return dict(creation_response_context)
293+
return creation_response_context
294294

295295
def _get_polling_response_interpolation_context(self, job: AsyncJob) -> Dict[str, Any]:
296296
"""
@@ -302,14 +302,14 @@ def _get_polling_response_interpolation_context(self, job: AsyncJob) -> Dict[str
302302
Returns:
303303
Dict[str, Any]: The interpolation context as a dictionary.
304304
"""
305-
polling_response_context = self._polling_job_response_by_id[job.api_job_id()].json()
305+
polling_response_context = dict(self._polling_job_response_by_id[job.api_job_id()].json())
306306
polling_response_context["headers"] = self._polling_job_response_by_id[
307307
job.api_job_id()
308308
].headers
309309
polling_response_context["request"] = self._polling_job_response_by_id[
310310
job.api_job_id()
311311
].request
312-
return dict(polling_response_context)
312+
return polling_response_context
313313

314314
def _get_create_job_stream_slice(self, job: AsyncJob) -> StreamSlice:
315315
stream_slice = StreamSlice(

0 commit comments

Comments
 (0)