File tree Expand file tree Collapse file tree 1 file changed +3
-3
lines changed Expand file tree Collapse file tree 1 file changed +3
-3
lines changed Original file line number Diff line number Diff line change @@ -61,6 +61,7 @@ def __init__(self, options):
6161 self .archiver = None
6262 self .sharding = None
6363 self .replset = None
64+ self .replset_sharded = None
6465 self .mongodumper = None
6566 self .oplogtailer = None
6667 self .oplog_resolver = None
@@ -198,7 +199,6 @@ def run(self):
198199 replset_name = secondary ['replSet' ]
199200
200201 self .secondaries [replset_name ] = secondary
201- self .replset .close ()
202202 except Exception , e :
203203 self .exception ("Problem getting shard secondaries! Error: %s" % e )
204204
@@ -237,15 +237,15 @@ def run(self):
237237
238238 # get shard secondaries
239239 try :
240- self .replset = ReplsetSharded (
240+ self .replset_sharded = ReplsetSharded (
241241 self .sharding ,
242242 self .db ,
243243 self .user ,
244244 self .password ,
245245 self .authdb ,
246246 self .max_repl_lag_secs
247247 )
248- self .secondaries = self .replset .find_secondaries ()
248+ self .secondaries = self .replset_sharded .find_secondaries ()
249249 except Exception , e :
250250 self .exception ("Problem getting shard secondaries! Error: %s" % e )
251251
You can’t perform that action at this time.
0 commit comments