diff --git a/beem/blockchain.py b/beem/blockchain.py index 195c2671a83d49a3c17ca5a9e5e0d0749919743f..9c35a6a340ea32653bce0957770a7f8926649532 100644 --- a/beem/blockchain.py +++ b/beem/blockchain.py @@ -398,8 +398,9 @@ class Blockchain(object): pool = Pool(thread_num, batch_mode=True) if threading: steem_instance = [] + nodelist = self.steem.rpc.nodes.export_working_nodes() for i in range(thread_num): - steem_instance.append(stm.Steem(node=self.steem.rpc.nodes, + steem_instance.append(stm.Steem(node=nodelist, num_retries=self.steem.rpc.num_retries, num_retries_call=self.steem.rpc.num_retries_call, timeout=self.steem.rpc.timeout)) diff --git a/beemapi/node.py b/beemapi/node.py index 4995eaabed88121dee7f0da989b23b3c32c335cc..e570f4a468775835164ed1256f2c2b17aaeefc7b 100644 --- a/beemapi/node.py +++ b/beemapi/node.py @@ -66,11 +66,15 @@ class Nodes(list): next = __next__ # Python 2 - def __repr__(self): + def export_working_nodes(self): nodes_list = [] for i in range(len(self)): if self.num_retries < 0 or self[i].error_cnt <= self.num_retries: nodes_list.append(self[i].url) + return nodes_list + + def __repr__(self): + nodes_list = self.export_working_nodes() return str(nodes_list) @property