log when we get an exception handling replication updates

This commit is contained in:
hera 2017-10-12 10:50:44 +00:00 committed by Richard van der Hoff
parent b8d8ed1ba9
commit f807f7f804

View File

@ -160,7 +160,11 @@ class ReplicationStreamer(object):
"Getting stream: %s: %s -> %s",
stream.NAME, stream.last_token, stream.upto_token
)
updates, current_token = yield stream.get_updates()
try:
updates, current_token = yield stream.get_updates()
except:
logger.info("Failed to handle stream %s", stream.NAME)
raise
logger.debug(
"Sending %d updates to %d connections",