def serialize()

in pulsar/functions/serde.py [0:0]

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

    def serialize(self, input):
        if type(input) in self._types:
            return str(input).encode('utf-8')
        if type(input) == bytes:
            return input
        raise TypeError("IdentitySerde cannot serialize object of type %s" % type(input))