x

langserve/api_handler.py

@@ -62,7 +62,7 @@
     PublicTraceLink,
     PublicTraceLinkCreateRequest,
 )
-from langserve.serialization import WellKnownLCSerializer, Serializer
+from langserve.serialization import Serializer, WellKnownLCSerializer
 from langserve.validation import (
     BatchBaseResponse,
     BatchRequestShallowValidator,

langserve/serialization.py

@@ -157,9 +157,9 @@ def _decode_event_data(value: Any) -> Any:
 
 
 class Serializer(abc.ABC):
-    @abc.abstractmethod
     def dumpd(self, obj: Any) -> Any:
         """Convert the given object to a JSON serializable object."""
+        return orjson.loads(self.dumps(obj))
 
     @abc.abstractmethod
     def dumps(self, obj: Any) -> bytes:
@@ -169,16 +169,12 @@ def dumps(self, obj: Any) -> bytes:
     def loads(self, s: bytes) -> Any:
         """Load the given JSON string."""
 
-    @abc.abstractmethod
-    def loadd(self, obj: Any) -> Any:
-        """Load the given object."""
+    def loads(self, s: bytes) -> Any:
+        """Load the given JSON string."""
+        return self.loadd(orjson.loads(s))
 
 
 class WellKnownLCSerializer(Serializer):
-    def dumpd(self, obj: Any) -> Any:
-        """Convert the given object to a JSON serializable object."""
-        return orjson.loads(orjson.dumps(obj, default=default))
-
     def dumps(self, obj: Any) -> bytes:
         """Dump the given object as a JSON string."""
         return orjson.dumps(obj, default=default)
@@ -187,10 +183,6 @@ def loadd(self, obj: Any) -> Any:
         """Load the given object."""
         return _decode_lc_objects(obj)
 
-    def loads(self, s: bytes) -> Any:
-        """Load the given JSON string."""
-        return self.loadd(orjson.loads(s))
-
 
 def _project_top_level(model: BaseModel) -> Dict[str, Any]:
     """Project the top level of the model as dict."""