in pulsar/schema/schema_avro.py [0:0]
def _get_serialized_value(self, x):
if isinstance(x, enum.Enum):
return x.name
elif isinstance(x, Record):
return self.encode_dict(x.__dict__)
elif isinstance(x, list):
arr = []
for item in x:
arr.append(self._get_serialized_value(item))
return arr
elif isinstance(x, dict):
return self.encode_dict(x)
else:
return x