Handle subrecords in JsonSchema encoding (#4023)

apache · Apr 12, 2019 · c92d4e0 · c92d4e0
1 parent 9d6de67
commit c92d4e0
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/pulsar-client-cpp/python/pulsar/schema/schema.py b/pulsar-client-cpp/python/pulsar/schema/schema.py
@@ -80,7 +80,7 @@ def __init__(self, record_cls):
 
     def encode(self, obj):
         self._validate_object_type(obj)
-        return json.dumps(obj.__dict__, indent=True).encode('utf-8')
+        return json.dumps(obj.__dict__, default=lambda o: o.__dict__, indent=True).encode('utf-8')
 
     def decode(self, data):
         return self._record_cls(**json.loads(data))