Skip to content

Commit 16aa37c

Browse files
author
Oleksandr Bazarnov
committed
renamed to polling_job_timeout
1 parent 97cc9c4 commit 16aa37c

File tree

4 files changed

+5
-5
lines changed

4 files changed

+5
-5
lines changed

airbyte_cdk/sources/declarative/declarative_component_schema.yaml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -3381,7 +3381,7 @@ definitions:
33813381
anyOf:
33823382
- "$ref": "#/definitions/CustomRequester"
33833383
- "$ref": "#/definitions/HttpRequester"
3384-
polling_timeout:
3384+
polling_job_timeout:
33853385
description: The time in minutes after which the single Async Job should be considered as Timed Out.
33863386
anyOf:
33873387
- type: integer

airbyte_cdk/sources/declarative/models/declarative_component_schema.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -2354,7 +2354,7 @@ class AsyncRetriever(BaseModel):
23542354
...,
23552355
description="Requester component that describes how to prepare HTTP requests to send to the source API to fetch the status of the running async job.",
23562356
)
2357-
polling_timeout: Optional[Union[int, str]] = Field(
2357+
polling_job_timeout: Optional[Union[int, str]] = Field(
23582358
None,
23592359
description="The time in minutes after which the single Async Job should be considered as Timed Out.",
23602360
)

airbyte_cdk/sources/declarative/parsers/model_to_component_factory.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -2943,11 +2943,11 @@ def _get_job_timeout() -> datetime.timedelta:
29432943
user_defined_timeout: Optional[int] = (
29442944
int(
29452945
InterpolatedString.create(
2946-
str(model.polling_timeout),
2946+
str(model.polling_job_timeout),
29472947
parameters={},
29482948
).eval(config)
29492949
)
2950-
if model.polling_timeout
2950+
if model.polling_job_timeout
29512951
else None
29522952
)
29532953

airbyte_cdk/sources/declarative/requesters/http_job_repository.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -45,7 +45,7 @@ class AsyncHttpJobRepository(AsyncJobRepository):
4545
status_mapping: Mapping[str, AsyncJobStatus]
4646
download_target_extractor: DpathExtractor
4747

48-
# timeout for the job to be completed, passed from `polling_timeout`
48+
# timeout for the job to be completed, passed from `polling_job_timeout`
4949
job_timeout: Optional[timedelta] = None
5050

5151
record_extractor: RecordExtractor = field(

0 commit comments

Comments
 (0)