Require Pydantic 2.0+

Required for Python 3.14 support

Fixes #454

Fixes #452

Author: akx

pyproject.toml

@@ -13,7 +13,7 @@ requires-python = ">=3.8"
 dependencies = [
     "httpx>=0.21.0,<1",
     "packaging",
-    "pydantic>1.10.7",
+    "pydantic>=2.0",
     "typing_extensions>=4.5.0",
 ]
 

replicate/account.py

@@ -17,7 +17,7 @@ class Account(Resource):
     name: str
     """The name of the account."""
 
-    github_url: Optional[str]
+    github_url: Optional[str] = None
     """The GitHub URL of the account."""
 
 

replicate/deployment.py

@@ -1,5 +1,6 @@
 from typing import TYPE_CHECKING, Any, Dict, Optional, Tuple, TypedDict, Union
 
+import pydantic
 from typing_extensions import Unpack, deprecated
 
 from replicate.account import Account
@@ -13,12 +14,6 @@
 )
 from replicate.resource import Namespace, Resource
 
-try:
-    from pydantic import v1 as pydantic  # type: ignore
-except ImportError:
-    import pydantic  # type: ignore
-
-
 if TYPE_CHECKING:
     from replicate.client import Client
     from replicate.prediction import Predictions
@@ -66,7 +61,7 @@ class Release(Resource):
         The time the release was created.
         """
 
-        created_by: Optional[Account]
+        created_by: Optional[Account] = None
         """
         The account that created the release.
         """
@@ -96,7 +91,7 @@ class Configuration(Resource):
         The deployment configuration.
         """
 
-    current_release: Optional[Release]
+    current_release: Optional[Release] = None
     """
     The current release of the deployment.
     """

replicate/file.py

@@ -41,7 +41,7 @@ class File(Resource):
     created_at: str
     """The time the file was created."""
 
-    expires_at: Optional[str]
+    expires_at: Optional[str] = None
     """The time the file will expire."""
 
     urls: Dict[str, str]

replicate/model.py

@@ -1,5 +1,6 @@
 from typing import TYPE_CHECKING, Any, Dict, Literal, Optional, Tuple, Union, overload
 
+import pydantic
 from typing_extensions import NotRequired, TypedDict, Unpack, deprecated
 
 from replicate.exceptions import ReplicateException
@@ -15,12 +16,6 @@
 from replicate.resource import Namespace, Resource
 from replicate.version import Version, Versions
 
-try:
-    from pydantic import v1 as pydantic  # type: ignore
-except ImportError:
-    import pydantic  # type: ignore
-
-
 if TYPE_CHECKING:
     from replicate.client import Client
     from replicate.prediction import Predictions
@@ -48,7 +43,7 @@ class Model(Resource):
     The name of the model.
     """
 
-    description: Optional[str]
+    description: Optional[str] = None
     """
     The description of the model.
     """
@@ -58,17 +53,17 @@ class Model(Resource):
     The visibility of the model. Can be 'public' or 'private'.
     """
 
-    github_url: Optional[str]
+    github_url: Optional[str] = None
     """
     The GitHub URL of the model.
     """
 
-    paper_url: Optional[str]
+    paper_url: Optional[str] = None
     """
     The URL of the paper related to the model.
     """
 
-    license_url: Optional[str]
+    license_url: Optional[str] = None
     """
     The URL of the license for the model.
     """
@@ -78,17 +73,17 @@ class Model(Resource):
     The number of runs of the model.
     """
 
-    cover_image_url: Optional[str]
+    cover_image_url: Optional[str] = None
     """
     The URL of the cover image for the model.
     """
 
-    default_example: Optional[Prediction]
+    default_example: Optional[Prediction] = None
     """
     The default example of the model.
     """
 
-    latest_version: Optional[Version]
+    latest_version: Optional[Version] = None
     """
     The latest version of the model.
     """
@@ -137,7 +132,7 @@ def reload(self) -> None:
         """
 
         obj = self._client.models.get(f"{self.owner}/{self.name}")
-        for name, value in obj.dict().items():
+        for name, value in obj.model_dump().items():
             setattr(self, name, value)
 
 

replicate/pagination.py

@@ -11,10 +11,7 @@
     Union,
 )
 
-try:
-    from pydantic import v1 as pydantic  # type: ignore
-except ImportError:
-    import pydantic  # type: ignore
+import pydantic
 
 from replicate.resource import Resource
 

replicate/prediction.py

@@ -17,6 +17,7 @@
 )
 
 import httpx
+import pydantic
 from typing_extensions import NotRequired, TypedDict, Unpack
 
 from replicate.exceptions import ModelError, ReplicateError
@@ -27,11 +28,6 @@
 from replicate.stream import EventSource
 from replicate.version import Version
 
-try:
-    from pydantic import v1 as pydantic  # type: ignore
-except ImportError:
-    import pydantic  # type: ignore
-
 if TYPE_CHECKING:
     from replicate.client import Client
     from replicate.deployment import Deployment
@@ -58,31 +54,31 @@ class Prediction(Resource):
     status: Literal["starting", "processing", "succeeded", "failed", "canceled"]
     """The status of the prediction."""
 
-    input: Optional[Dict[str, Any]]
+    input: Optional[Dict[str, Any]] = None
     """The input to the prediction."""
 
-    output: Optional[Any]
+    output: Optional[Any] = None
     """The output of the prediction."""
 
-    logs: Optional[str]
+    logs: Optional[str] = None
     """The logs of the prediction."""
 
-    error: Optional[str]
+    error: Optional[str] = None
     """The error encountered during the prediction, if any."""
 
-    metrics: Optional[Dict[str, Any]]
+    metrics: Optional[Dict[str, Any]] = None
     """Metrics for the prediction."""
 
-    created_at: Optional[str]
+    created_at: Optional[str] = None
     """When the prediction was created."""
 
-    started_at: Optional[str]
+    started_at: Optional[str] = None
     """When the prediction was started."""
 
-    completed_at: Optional[str]
+    completed_at: Optional[str] = None
     """When the prediction was completed, if finished."""
 
-    urls: Optional[Dict[str, str]]
+    urls: Optional[Dict[str, str]] = None
     """
     URLs associated with the prediction.
 
@@ -214,7 +210,7 @@ def cancel(self) -> None:
         """
 
         canceled = self._client.predictions.cancel(self.id)
-        for name, value in canceled.dict().items():
+        for name, value in canceled.model_dump().items():
             setattr(self, name, value)
 
     async def async_cancel(self) -> None:
@@ -223,7 +219,7 @@ async def async_cancel(self) -> None:
         """
 
         canceled = await self._client.predictions.async_cancel(self.id)
-        for name, value in canceled.dict().items():
+        for name, value in canceled.model_dump().items():
             setattr(self, name, value)
 
     def reload(self) -> None:
@@ -232,7 +228,7 @@ def reload(self) -> None:
         """
 
         updated = self._client.predictions.get(self.id)
-        for name, value in updated.dict().items():
+        for name, value in updated.model_dump().items():
             setattr(self, name, value)
 
     async def async_reload(self) -> None:
@@ -241,7 +237,7 @@ async def async_reload(self) -> None:
         """
 
         updated = await self._client.predictions.async_get(self.id)
-        for name, value in updated.dict().items():
+        for name, value in updated.model_dump().items():
             setattr(self, name, value)
 
     def output_iterator(self) -> Iterator[Any]:

replicate/resource.py

@@ -1,10 +1,7 @@
 import abc
 from typing import TYPE_CHECKING
 
-try:
-    from pydantic import v1 as pydantic  # type: ignore
-except ImportError:
-    import pydantic  # type: ignore
+import pydantic
 
 if TYPE_CHECKING:
     from replicate.client import Client

replicate/stream.py

@@ -11,18 +11,13 @@
 )
 
 import httpx
+import pydantic
 from typing_extensions import Unpack
 
 from replicate import identifier
 from replicate.exceptions import ReplicateError
 from replicate.helpers import transform_output
 
-try:
-    from pydantic import v1 as pydantic  # type: ignore
-except ImportError:
-    import pydantic  # type: ignore
-
-
 if TYPE_CHECKING:
     from replicate.client import Client
     from replicate.identifier import ModelVersionIdentifier
@@ -49,7 +44,7 @@ class EventType(Enum):
     event: EventType
     data: str
     id: str
-    retry: Optional[int]
+    retry: Optional[int] = None
 
     def __str__(self) -> str:
         if self.event == ServerSentEvent.EventType.OUTPUT:

replicate/training.py

@@ -11,6 +11,7 @@
     overload,
 )
 
+import pydantic
 from typing_extensions import NotRequired, Unpack
 
 from replicate.helpers import async_encode_json, encode_json
@@ -20,11 +21,6 @@
 from replicate.resource import Namespace, Resource
 from replicate.version import Version
 
-try:
-    from pydantic import v1 as pydantic  # type: ignore
-except ImportError:
-    import pydantic  # type: ignore
-
 if TYPE_CHECKING:
     from replicate.client import Client
     from replicate.file import FileEncodingStrategy
@@ -46,34 +42,34 @@ class Training(Resource):
     version: Union[str, Version]
     """The version of the model used to create the training."""
 
-    destination: Optional[str]
+    destination: Optional[str] = None
     """The model destination of the training."""
 
     status: Literal["starting", "processing", "succeeded", "failed", "canceled"]
     """The status of the training."""
 
-    input: Optional[Dict[str, Any]]
+    input: Optional[Dict[str, Any]] = None
     """The input to the training."""
 
-    output: Optional[Any]
+    output: Optional[Any] = None
     """The output of the training."""
 
-    logs: Optional[str]
+    logs: Optional[str] = None
     """The logs of the training."""
 
-    error: Optional[str]
+    error: Optional[str] = None
     """The error encountered during the training, if any."""
 
-    created_at: Optional[str]
+    created_at: Optional[str] = None
     """When the training was created."""
 
-    started_at: Optional[str]
+    started_at: Optional[str] = None
     """When the training was started."""
 
-    completed_at: Optional[str]
+    completed_at: Optional[str] = None
     """When the training was completed, if finished."""
 
-    urls: Optional[Dict[str, str]]
+    urls: Optional[Dict[str, str]] = None
     """
     URLs associated with the training.
 
@@ -88,7 +84,7 @@ def cancel(self) -> None:
         """
 
         canceled = self._client.trainings.cancel(self.id)
-        for name, value in canceled.dict().items():
+        for name, value in canceled.model_dump().items():
             setattr(self, name, value)
 
     async def async_cancel(self) -> None:
@@ -97,7 +93,7 @@ async def async_cancel(self) -> None:
         """
 
         canceled = await self._client.trainings.async_cancel(self.id)
-        for name, value in canceled.dict().items():
+        for name, value in canceled.model_dump().items():
             setattr(self, name, value)
 
     def reload(self) -> None:
@@ -106,7 +102,7 @@ def reload(self) -> None:
         """
 
         updated = self._client.trainings.get(self.id)
-        for name, value in updated.dict().items():
+        for name, value in updated.model_dump().items():
             setattr(self, name, value)
 
     async def async_reload(self) -> None:
@@ -115,7 +111,7 @@ async def async_reload(self) -> None:
         """
 
         updated = await self._client.trainings.async_get(self.id)
-        for name, value in updated.dict().items():
+        for name, value in updated.model_dump().items():
             setattr(self, name, value)