Skip to content

Commit 492d399

Browse files
Only set read pref tags if boolean is True, make only the tailing and dumping use them.
1 parent 6ce36a7 commit 492d399

File tree

2 files changed

+5
-3
lines changed

2 files changed

+5
-3
lines changed

mongodb_consistent_backup/Common/DB.py

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -12,11 +12,13 @@
1212

1313

1414
class DB:
15-
def __init__(self, uri, config, do_replset=False, read_pref='primaryPreferred', do_connect=True, conn_timeout=5000, retries=5):
15+
def __init__(self, uri, config, do_replset=False, read_pref='primaryPreferred', do_rp_tags=False,
16+
do_connect=True, conn_timeout=5000, retries=5):
1617
self.uri = uri
1718
self.config = config
1819
self.do_replset = do_replset
1920
self.read_pref = read_pref
21+
self.do_rp_tags = do_rp_tags
2022
self.do_connect = do_connect
2123
self.conn_timeout = conn_timeout
2224
self.retries = retries
@@ -57,7 +59,7 @@ def client_opts(self):
5759
"readPreference": self.read_pref,
5860
"w": "majority"
5961
})
60-
if self.read_pref_tags:
62+
if self.do_rp_tags and self.read_pref_tags:
6163
self.read_pref_tags = self.read_pref_tags.replace(" ", "")
6264
opts["readPreferenceTags"] = self.read_pref_tags
6365
if self.do_ssl():

mongodb_consistent_backup/Oplog/Tailer/TailThread.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -88,7 +88,7 @@ def status(self):
8888

8989
def connect(self):
9090
if not self.db:
91-
self.db = DB(self.uri, self.config, True, 'secondary')
91+
self.db = DB(self.uri, self.config, True, 'secondary', True)
9292
return self.db.connection()
9393

9494
def run(self):

0 commit comments

Comments
 (0)