Use all nodes for s3 creds

This commit is contained in:
Andrey Berezin 2023-09-19 18:14:32 +03:00 committed by Andrey Berezin
parent fc1f373477
commit 602de43bff
3 changed files with 10 additions and 2 deletions

View file

@ -72,6 +72,7 @@ class DefaultRunner(RunnerBase):
def prepare(
self,
load_params: LoadParams,
cluster_nodes: list[ClusterNode],
nodes_under_load: list[ClusterNode],
k6_dir: str,
):
@ -81,7 +82,7 @@ class DefaultRunner(RunnerBase):
with reporter.step("Init s3 client on loaders"):
storage_node = nodes_under_load[0].service(StorageNode)
s3_public_keys = [
node.service(S3Gate).get_wallet_public_key() for node in nodes_under_load
node.service(S3Gate).get_wallet_public_key() for node in cluster_nodes
]
grpc_peer = storage_node.get_rpc_endpoint()
@ -290,6 +291,7 @@ class LocalRunner(RunnerBase):
def prepare(
self,
load_params: LoadParams,
cluster_nodes: list[ClusterNode],
nodes_under_load: list[ClusterNode],
k6_dir: str,
):