File tree Expand file tree Collapse file tree 1 file changed +7
-1
lines changed Expand file tree Collapse file tree 1 file changed +7
-1
lines changed Original file line number Diff line number Diff line change @@ -149,6 +149,12 @@ def diff(first, second):
149
149
second = set (second )
150
150
return [item for item in first if item not in second ]
151
151
152
+
153
+ @backoff .on_exception (
154
+ backoff .expo ,
155
+ requests .exceptions .ConnectionError ,
156
+ max_tries = 10
157
+ )
152
158
# Check if the _membership API on all (known) CouchDB nodes have the same values.
153
159
# Returns true if sam. False in any other situation.
154
160
def are_nodes_in_sync (names ):
@@ -197,7 +203,7 @@ def sleep_forever():
197
203
connect_the_dots (peer_names )
198
204
print ("Got the following peers' fqdm from DNS lookup:" ,peer_names ,flush = True )
199
205
# loop until all CouchDB nodes discovered
200
- while not are_nodes_in_sync (names ):
206
+ while not are_nodes_in_sync (peer_names ):
201
207
time .sleep (5 )
202
208
peer_names = discover_peers (construct_service_record ())
203
209
connect_the_dots (peer_names )
You can’t perform that action at this time.
0 commit comments