Raise exception of Oplog/Tailer threads exit before starting

timvaillancourt · timvaillancourt · commit 971fe7cb325e · 2017-05-01T17:28:50.000+02:00
diff --git a/mongodb_consistent_backup/Oplog/Tailer/Tailer.py b/mongodb_consistent_backup/Oplog/Tailer/Tailer.py
@@ -64,6 +64,8 @@ def run(self):
             }
             self.shards[shard]['thread'].start()
             while not oplog_state.get('running'):
+                if self.shards[shard]['thread'].exitcode:
+                    raise OperationError("Oplog tailer for %s failed with exit code %i!" % (mongo_uri, self.shards[shard]['thread'].exitcode))
                 sleep(0.5)
 
     def stop(self, kill=False, sleep_secs=0.5):

Original file line number	Diff line number	Diff line change
`@@ -64,6 +64,8 @@ def run(self):`
`64`	`64`	`}`
`65`	`65`	`self.shards[shard]['thread'].start()`
`66`	`66`	`while not oplog_state.get('running'):`
	`67`	`+ if self.shards[shard]['thread'].exitcode:`
	`68`	`+ raise OperationError("Oplog tailer for %s failed with exit code %i!" % (mongo_uri, self.shards[shard]['thread'].exitcode))`
`67`	`69`	`sleep(0.5)`
`68`	`70`
`69`	`71`	`def stop(self, kill=False, sleep_secs=0.5):`