in pulsar/schema/schema_avro.py [0:0]
def encode_dict(self, d): obj = {} for k, v in d.items(): obj[k] = self._get_serialized_value(v) return obj