.

Author: ikapriz-objectrocket

mongodb_consistent_backup/Backup/Mongodump/MongodumpThread.py

@@ -245,20 +245,24 @@ def run(self):
         except Exception, e:
             logging.exception("Error performing mongodump: %s" % e)
 
-        try:
-            oplog = Oplog(self.oplog_file, self.dump_gzip)
-            oplog.load()
-        except Exception, e:
-            logging.exception("Error loading oplog: %s" % e)
+        oplog = None
+        if self.oplog_enabled_parse():
+          try:
+              oplog = Oplog(self.oplog_file, self.dump_gzip)
+              oplog.load()
+          except Exception, e:
+              logging.exception("Error loading oplog: %s" % e)
 
         self.state.set('running', False)
         self.state.set('completed', True)
-        self.state.set('count', oplog.count())
-        self.state.set('first_ts', oplog.first_ts())
-        self.state.set('last_ts', oplog.last_ts())
+        if self.oplog_enabled_parse():
+          self.state.set('count', oplog.count())
+          self.state.set('first_ts', oplog.first_ts())
+          self.state.set('last_ts', oplog.last_ts())
         self.timer.stop(self.timer_name)
 
-        log_msg_extra = "%i oplog changes" % oplog.count()
-        if oplog.last_ts():
-            log_msg_extra = "%s, end ts: %s" % (log_msg_extra, oplog.last_ts())
+        if self.oplog_enabled_parse():
+          log_msg_extra = "%i oplog changes" % oplog.count()
+          if oplog.last_ts():
+              log_msg_extra = "%s, end ts: %s" % (log_msg_extra, oplog.last_ts())
         logging.info("Backup %s completed in %.2f seconds, %s" % (self.uri, self.timer.duration(self.timer_name), log_msg_extra))