def decode_message()

in pulsar/schema/schema_avro.py [0:0]

• 11 lines of code
• 3 McCabe index (conditional complexity)

        def decode_message(self, msg: _pulsar.Message):
            if self._client is None:
                return self.decode(msg.data())
            topic = msg.topic_name()
            version = msg.int_schema_version()
            try:
                writer_schema = self._get_writer_schema(topic, version)
                return self._decode_bytes(msg.data(), writer_schema)
            except Exception as e:
                self._logger.error('Failed to get schema info of {topic} version {version}: {e}')
                return self._decode_bytes(msg.data(), self._schema)