File tree Expand file tree Collapse file tree 1 file changed +5
-5
lines changed Expand file tree Collapse file tree 1 file changed +5
-5
lines changed Original file line number Diff line number Diff line change @@ -50,14 +50,14 @@ def get_consistent_end_ts(self):
5050 def run (self ):
5151 logging .info ("Resolving oplogs using %i threads max" % self .thread_count )
5252
53- tailed_oplogs = []
53+ delete_oplogs = []
5454 self .end_ts = self .get_consistent_end_ts ()
5555 for host in self .backup_oplogs :
5656 for port in self .backup_oplogs [host ]:
5757 backup_oplog = self .backup_oplogs [host ][port ]
5858 if host in self .tailed_oplogs and port in self .tailed_oplogs [host ]:
5959 tailed_oplog = self .tailed_oplogs [host ][port ]
60- tailed_oplogs .append ({
60+ delete_oplogs .append ({
6161 'host' : host ,
6262 'port' : port ,
6363 'file' : tailed_oplog ['file' ]
@@ -88,10 +88,10 @@ def run(self):
8888 self ._pool .close ()
8989 self ._pool .join ()
9090
91- for oplog_file in tailed_oplogs :
91+ for delete_oplog in delete_oplogs :
9292 try :
93- logging .debug ("Deleting tailed oplog file for %s:%s" % (oplog_file ['host' ], oplog_file ['port' ]))
94- os .remove (oplog_file ['file' ])
93+ logging .debug ("Deleting tailed oplog file for %s:%s" % (delete_oplog ['host' ], delete_oplog ['port' ]))
94+ os .remove (delete_oplog ['file' ])
9595 except Exception , e :
9696 logging .fatal ("Deleting of tailed oplog file %s failed! Error: %s" % (oplog_file , e ))
9797 raise e
You can’t perform that action at this time.
0 commit comments