in transcoder/Transcoder.py [0:0]
def handle_exception(self, raw_record, message, exception):
"""Process exceptions encountered in the message processing runtime"""
if message is not None:
self.message_parser.increment_error_summary_count(message.name)
else:
self.message_parser.increment_error_summary_count()
self.error_writer.write_error(raw_record, message, exception)
if self.continue_on_error is False:
raise exception