diff --git a/oplogreplay/oplogwatcher.py b/oplogreplay/oplogwatcher.py index 133c644..06350e8 100644 --- a/oplogreplay/oplogwatcher.py +++ b/oplogreplay/oplogwatcher.py @@ -72,8 +72,11 @@ def start(self): logging.warning(e) time.sleep(self.poll_time) except OperationFailure, e: - logging.exception(e) + logging.exception("Error") time.sleep(self.poll_time) + except Exception, e: + logging.error("Error handling %r" % op) + raise def stop(self): self.running = False