From 97b330db6ebba8b2dfedd6375f7470c975751593 Mon Sep 17 00:00:00 2001
From: vtexier <vit@free.fr>
Date: Sun, 16 Feb 2020 19:46:22 +0100
Subject: [PATCH] [fix] fix missing endpoint info with random_offline node
---
src/sakia/data/connectors/bma.py | 14 +++++++++++++-
1 file changed, 13 insertions(+), 1 deletion(-)
diff --git a/src/sakia/data/connectors/bma.py b/src/sakia/data/connectors/bma.py
index 57ff5b43..34adaf52 100644
--- a/src/sakia/data/connectors/bma.py
+++ b/src/sakia/data/connectors/bma.py
@@ -225,9 +225,21 @@ class BmaConnector:
)
)
if random_offline_node:
+ node = random_offline_node[0]
+ endpoints = filter_endpoints(request, [node])
+ if not endpoints:
+ continue
+ endpoint = random.choice(endpoints)
+ self._logger.debug(
+ "Requesting {0} on endpoint {1}".format(
+ str(request.__name__), str(endpoint)
+ )
+ )
+ # create client
+ _client = client.Client(endpoint, session, proxy=self._user_parameters.proxy())
futures.append(
self._verified_request(
- random_offline_node[0],
+ node,
_client(request, **req_args)
)
)
--
GitLab