Skip to content

Commit e97af42

Browse files
Fix disabling of oplog tailer (#175)
1 parent d0b5014 commit e97af42

File tree

2 files changed

+4
-2
lines changed

2 files changed

+4
-2
lines changed

mongodb_consistent_backup/Main.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -414,7 +414,7 @@ def run(self):
414414
self.db.close()
415415

416416
# resolve/merge tailed oplog into mongodump oplog.bson to a consistent point for all shards
417-
if self.backup.task.lower() == "mongodump" and self.oplogtailer:
417+
if self.backup.task.lower() == "mongodump" and self.oplogtailer.enabled():
418418
self.resolver = Resolver(
419419
self.manager,
420420
self.config,

mongodb_consistent_backup/Oplog/Tailer/Tailer.py

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -30,7 +30,9 @@ def __init__(self, manager, config, timer, base_dir, backup_dir, replsets, backu
3030
self._summary = {}
3131

3232
def enabled(self):
33-
if self._enabled.lower().strip() != 'false':
33+
if isinstance(self._enabled, bool):
34+
return self._enabled
35+
elif isinstance(self._enabled, str) and self._enabled.strip().lower() != 'false':
3436
return True
3537
return False
3638

0 commit comments

Comments
 (0)