File tree Expand file tree Collapse file tree 2 files changed +8
-4
lines changed Expand file tree Collapse file tree 2 files changed +8
-4
lines changed Original file line number Diff line number Diff line change @@ -57,7 +57,11 @@ def run(self):
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 (tailed_oplog ['file' ])
60+ tailed_oplogs .append ({
61+ 'host' : host ,
62+ 'port' : port ,
63+ 'file' : tailed_oplog ['file' ]
64+ })
6165
6266 if backup_oplog ['last_ts' ] is None and tailed_oplog ['last_ts' ] is None :
6367 logging .info ("No oplog changes to resolve for %s:%s" % (host , port ))
@@ -86,8 +90,8 @@ def run(self):
8690
8791 for oplog_file in tailed_oplogs :
8892 try :
89- logging .debug ("Deleting tailed oplog file for %s:%s" % (host , port ))
90- os .remove (oplog_file )
93+ logging .debug ("Deleting tailed oplog file for %s:%s" % (oplog_file [ ' host' ], oplog_file [ ' port' ] ))
94+ os .remove (oplog_file [ 'file' ] )
9195 except Exception , e :
9296 logging .fatal ("Deleting of tailed oplog file %s failed! Error: %s" % (oplog_file , e ))
9397 raise e
Original file line number Diff line number Diff line change 1- 0.3.0
1+ 0.3.1
You can’t perform that action at this time.
0 commit comments