Changed port name to match with kubernetes changes in wls

This commit is contained in:
Alberto Soutullo 2023-03-16 15:51:12 +01:00
parent 2b52e68873
commit 8de3cd6968
1 changed files with 1 additions and 1 deletions

View File

@ -102,7 +102,7 @@ def _select_emitter_with_topic(random_emitters):
# Pick an emitter at random from the emitters list
random_emitter, random_emitter_info = random.choice(list(random_emitters.items()))
emitter_address = f"http://{random_emitter_info['ip_address']}:" \
f"{random_emitter_info['ports']['rpc_' + random_emitter][0]}/"
f"{random_emitter_info['ports']['rpc-' + random_emitter][0]}/"
emitter_topics = random_emitter_info["topics"]
# Pick a topic at random from the topics supported by the emitter
emitter_topic = random.choice(emitter_topics)