From 0c4ac4bdbe4b78ea0f79e79705f9fd0fd549de85 Mon Sep 17 00:00:00 2001
From: Holger <holger@nahrstaedt.de>
Date: Sat, 23 Jun 2018 09:28:33 +0200
Subject: [PATCH] export_working_nodes added to node
---
beem/blockchain.py | 3 ++-
beemapi/node.py | 6 +++++-
2 files changed, 7 insertions(+), 2 deletions(-)
diff --git a/beem/blockchain.py b/beem/blockchain.py
index 195c2671..9c35a6a3 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 4995eaab..e570f4a4 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
--
GitLab