These are part of the codegen serdes that point at the v1 client, they are unchanged

Author: blast-hardcheese

src/replit_river/v2/client.py

@@ -7,12 +7,8 @@
 
 from opentelemetry import trace
 from opentelemetry.trace import Span, SpanKind, Status, StatusCode
-from pydantic import (
-    BaseModel,
-    ValidationInfo,
-)
 
-from replit_river.error_schema import ERROR_CODE_UNKNOWN, RiverError, RiverException
+from replit_river.error_schema import RiverError, RiverException
 from replit_river.transport_options import (
     HandshakeMetadataType,
     TransportOptions,
@@ -24,40 +20,6 @@
 tracer = trace.get_tracer(__name__)
 
 
-@dataclass(frozen=True)
-class RiverUnknownValue(BaseModel):
-    tag: Literal["RiverUnknownValue"]
-    value: Any
-
-
-class RiverUnknownError(RiverError):
-    pass
-
-
-def translate_unknown_value(
-    value: Any, handler: Callable[[Any], Any], info: ValidationInfo
-) -> Any | RiverUnknownValue:
-    try:
-        return handler(value)
-    except Exception:
-        return RiverUnknownValue(tag="RiverUnknownValue", value=value)
-
-
-def translate_unknown_error(
-    value: Any, handler: Callable[[Any], Any], info: ValidationInfo
-) -> Any | RiverUnknownError:
-    try:
-        return handler(value)
-    except Exception:
-        if isinstance(value, dict) and "code" in value and "message" in value:
-            return RiverUnknownError(
-                code=value["code"],
-                message=value["message"],
-            )
-        else:
-            return RiverUnknownError(code=ERROR_CODE_UNKNOWN, message="Unknown error")
-
-
 class Client(Generic[HandshakeMetadataType]):
     def __init__(
         self,