RetrySettings Class

Parallel RetrySettings.

Constructor

RetrySettings(*, timeout: int | str | None = None, max_retries: int | str | None = None, **kwargs: Any)

Name	Description
timeout Required	int Timeout in seconds for each invocation of the run() method. (optional) This value could be set through PipelineParameter.
max_retries Required	int The number of maximum tries for a failed or timeout mini batch. The range is [1, int.max]. This value could be set through PipelineParameter. A mini batch with dequeue count greater than this won't be processed again and will be deleted directly.

Name	Description
timeout	Default value: None
max_retries	Default value: None

get(key: Any, default: Any | None = None) -> Any

Name	Description
key Required
default	Default value: None

has_key(k: Any) -> bool

Name	Description
k Required

items() -> list

keys() -> list

update(*args: Any, **kwargs: Any) -> None

values() -> list

Is deze pagina nuttig?