Skip to content

There is currently no way to directly set the retry_policy on a Pipeline. #1049

Closed
@gorzell

Description

@gorzell

At least on the storage related clients you can only set RetryOptions which will be converted into a RetryPolicy. Since the RetryPolicy trait is now public, and even before that Policy was, it seems like you should be able to set that directly if you have custom code that satisfies the Policy trait. There is a hacky work around in the mean time:

 let options = StorageOptions::default().options(
            ClientOptions::default()
                .retry(RetryOptions::default().mode(RetryMode::None))
                .per_retry_policies(vec![flow_control.clone() as Arc<dyn Policy>]),
        );

Note: This only works if you have a patch that allows setting the StorageOptions on a client. WIP to get support for that into main.

Metadata

Metadata

Assignees

Labels

No labels
No labels

Type

No type

Projects

No projects

Milestone

No milestone

Relationships

None yet

Development

No branches or pull requests

Issue actions