fix: Add policies to adapters (#4277)

The configured policy wasn't being passed in and instead the default was
being used (e.g. in the s3 file provider)

Closes: #4276

Signed-off-by: Derek Higgins <derekh@redhat.com>
This commit is contained in:
Derek Higgins 2025-12-02 19:08:03 +00:00 committed by GitHub
parent 4ff0c25c52
commit 2fce5abe34
No known key found for this signature in database
GPG key ID: B5690EEEBB952194

View file

@ -374,6 +374,9 @@ async def instantiate_provider(
method = "get_adapter_impl" method = "get_adapter_impl"
args = [config, deps] args = [config, deps]
if "policy" in inspect.signature(getattr(module, method)).parameters:
args.append(policy)
elif isinstance(provider_spec, AutoRoutedProviderSpec): elif isinstance(provider_spec, AutoRoutedProviderSpec):
method = "get_auto_router_impl" method = "get_auto_router_impl"