diff --git a/karapace/protobuf/io.py b/karapace/protobuf/io.py index 3cc7445dc..6f4896a0b 100644 --- a/karapace/protobuf/io.py +++ b/karapace/protobuf/io.py @@ -256,13 +256,13 @@ def writer_process( # Writing happens in the forked process, catch is broad so exception will get communicated # back to calling process. except Exception as bare_exception: # pylint: disable=broad-exception-caught - try: - raise ProtobufTypeException(writer_schema, datum) from bare_exception - except ProtobufTypeException as protobuf_exception: - writer_queue.put(protobuf_exception) - raise protobuf_exception - except BaseException as base_exception: # pylint: disable=broad-exception-caught - writer_queue.put(base_exception) + #try: + # raise ProtobufTypeException(writer_schema, datum) from bare_exception + #except ProtobufTypeException as protobuf_exception: + # writer_queue.put(protobuf_exception) + # raise protobuf_exception + writer_queue.put(bare_exception) + raise bare_exception writer_queue.put(class_instance.SerializeToString())