Skip to content

Commit 687d621

Browse files
Merge pull request #4 from objectrocket/SRE-2645-revert-logic
Revert the check for the loops logic as it seems to never be executed
2 parents a230063 + 5346fa4 commit 687d621

File tree

1 file changed

+1
-5
lines changed
  • mongodb_consistent_backup/Oplog/Tailer

1 file changed

+1
-5
lines changed

mongodb_consistent_backup/Oplog/Tailer/Tailer.py

Lines changed: 1 addition & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -104,11 +104,7 @@ def stop(self, kill=False, sleep_secs=3):
104104

105105
# wait for replication to get in sync
106106
while state.get('last_ts') and state.get('last_ts') < timestamp:
107-
if self.shards[shard]['thread'].exitcode:
108-
logging.info('Not waiting for %s tailer to reach ts: %s, currrent: %s. Exit code: %i' % (uri, timestamp, state.get('last_ts'),self.shards[shard]['thread'].exitcode))
109-
break
110-
else:
111-
logging.info('Waiting for %s tailer to reach ts: %s, currrent: %s' % (uri, timestamp, state.get('last_ts')))
107+
logging.info('Waiting for %s tailer to reach ts: %s, currrent: %s' % (uri, timestamp, state.get('last_ts')))
112108
sleep(sleep_secs)
113109

114110
# set thread stop event

0 commit comments

Comments
 (0)