diff --git a/src/sakia/data/connectors/bma.py b/src/sakia/data/connectors/bma.py index 57ff5b4312189fd434f861290a7f91fd31ac4c92..34adaf523aa198b4190087e234418dd60d786bb2 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) ) )