Release 0.2.0

Author: polytomic-sdk-bot

README.md

@@ -21,7 +21,6 @@ pip install --upgrade polytomic
 from polytomic.client import Polytomic
 
 client = Polytomic(
-    x_polytomic_version="YOUR_X_POLYTOMIC_VERSION",
     token="YOUR_TOKEN",
 )
 ```
@@ -34,7 +33,6 @@ client = Polytomic(
 from polytomic.client import AsyncPolytomic
 
 client = AsyncPolytomic(
-    x_polytomic_version="YOUR_X_POLYTOMIC_VERSION",
     token="YOUR_TOKEN",
 )
 ```

poetry.lock

@@ -1,6 +1,6 @@
 [tool.poetry]
 name = "polytomic"
-version = "0.1.2"
+version = "0.2.0"
 description = ""
 readme = "README.md"
 authors = []

pyproject.toml

@@ -4,6 +4,7 @@
     ActivateSyncEnvelope,
     ActivateSyncInput,
     ActivateSyncOutput,
+    ApiError,
     ApiKeyResponse,
     ApiKeyResponseEnvelope,
     BulkDiscover,
@@ -60,6 +61,7 @@
     GetExecutionResponseSchema,
     GetIdentityResponseEnvelope,
     GetIdentityResponseSchema,
+    GetModelSyncSourceMetaEnvelope,
     Identity,
     IdentityFunction,
     JobResponse,
@@ -84,6 +86,7 @@
     ModelSyncField,
     ModelSyncResponse,
     ModelSyncResponseEnvelope,
+    ModelSyncSourceMetaResponse,
     Organization,
     OrganizationEnvelope,
     OrganizationsEnvelope,
@@ -109,6 +112,7 @@
     SchemaField,
     SchemaRecordsResponseEnvelope,
     Source,
+    SourceMeta,
     StartModelSyncResponseEnvelope,
     StartModelSyncResponseSchema,
     SupportedMode,
@@ -126,11 +130,19 @@
     WebhookListEnvelope,
     WorkTaskStatus,
 )
-from .errors import UnauthorizedError
+from .errors import (
+    BadRequestError,
+    ForbiddenError,
+    InternalServerError,
+    NotFoundError,
+    UnauthorizedError,
+    UnprocessableEntityError,
+)
 from .resources import (
     bulk_sync,
     connections,
     events,
+    identity,
     jobs,
     model_sync,
     models,
@@ -147,8 +159,10 @@
     "ActivateSyncEnvelope",
     "ActivateSyncInput",
     "ActivateSyncOutput",
+    "ApiError",
     "ApiKeyResponse",
     "ApiKeyResponseEnvelope",
+    "BadRequestError",
     "BulkDiscover",
     "BulkExecutionStatus",
     "BulkField",
@@ -198,13 +212,16 @@
     "ExecutionLogsResponseEnvelope",
     "ExecutionStatus",
     "Filter",
+    "ForbiddenError",
     "GetConnectionMetaEnvelope",
     "GetExecutionResponseEnvelope",
     "GetExecutionResponseSchema",
     "GetIdentityResponseEnvelope",
     "GetIdentityResponseSchema",
+    "GetModelSyncSourceMetaEnvelope",
     "Identity",
     "IdentityFunction",
+    "InternalServerError",
     "JobResponse",
     "JobResponseEnvelope",
     "JsonschemaForm",
@@ -227,6 +244,8 @@
     "ModelSyncField",
     "ModelSyncResponse",
     "ModelSyncResponseEnvelope",
+    "ModelSyncSourceMetaResponse",
+    "NotFoundError",
     "Organization",
     "OrganizationEnvelope",
     "OrganizationsEnvelope",
@@ -253,6 +272,7 @@
     "SchemaField",
     "SchemaRecordsResponseEnvelope",
     "Source",
+    "SourceMeta",
     "StartModelSyncResponseEnvelope",
     "StartModelSyncResponseSchema",
     "SupportedMode",
@@ -264,6 +284,7 @@
     "TargetResponse",
     "TargetResponseEnvelope",
     "UnauthorizedError",
+    "UnprocessableEntityError",
     "User",
     "UserEnvelope",
     "Webhook",
@@ -274,6 +295,7 @@
     "bulk_sync",
     "connections",
     "events",
+    "identity",
     "jobs",
     "model_sync",
     "models",

src/polytomic/__init__.py

@@ -9,6 +9,7 @@
 from .resources.bulk_sync.client import AsyncBulkSyncClient, BulkSyncClient
 from .resources.connections.client import AsyncConnectionsClient, ConnectionsClient
 from .resources.events.client import AsyncEventsClient, EventsClient
+from .resources.identity.client import AsyncIdentityClient, IdentityClient
 from .resources.jobs.client import AsyncJobsClient, JobsClient
 from .resources.model_sync.client import AsyncModelSyncClient, ModelSyncClient
 from .resources.models.client import AsyncModelsClient, ModelsClient
@@ -30,9 +31,7 @@ class Polytomic:
 
                                              Defaults to PolytomicEnvironment.DEFAULT
 
-        - x_polytomic_version: typing.Optional[typing.Literal["2023-04-25"]].
-
-        - token: typing.Optional[typing.Union[str, typing.Callable[[], str]]].
+        - token: typing.Union[str, typing.Callable[[], str]].
 
         - timeout: typing.Optional[float]. The timeout to be used, in seconds, for requests by default the timeout is 60 seconds, unless a custom httpx client is used, in which case a default is not set.
 
@@ -41,7 +40,6 @@ class Polytomic:
     from polytomic.client import Polytomic
 
     client = Polytomic(
-        x_polytomic_version="YOUR_X_POLYTOMIC_VERSION",
         token="YOUR_TOKEN",
     )
     """
@@ -51,29 +49,28 @@ def __init__(
         *,
         base_url: typing.Optional[str] = None,
         environment: PolytomicEnvironment = PolytomicEnvironment.DEFAULT,
-        x_polytomic_version: typing.Optional[typing.Literal["2023-04-25"]] = None,
-        token: typing.Optional[typing.Union[str, typing.Callable[[], str]]] = None,
+        token: typing.Union[str, typing.Callable[[], str]],
         timeout: typing.Optional[float] = None,
         httpx_client: typing.Optional[httpx.Client] = None
     ):
         _defaulted_timeout = timeout if timeout is not None else 60 if httpx_client is None else None
         self._client_wrapper = SyncClientWrapper(
             base_url=_get_base_url(base_url=base_url, environment=environment),
-            x_polytomic_version=x_polytomic_version,
             token=token,
             httpx_client=httpx.Client(timeout=_defaulted_timeout) if httpx_client is None else httpx_client,
             timeout=_defaulted_timeout,
         )
         self.bulk_sync = BulkSyncClient(client_wrapper=self._client_wrapper)
         self.connections = ConnectionsClient(client_wrapper=self._client_wrapper)
+        self.model_sync = ModelSyncClient(client_wrapper=self._client_wrapper)
         self.schemas = SchemasClient(client_wrapper=self._client_wrapper)
         self.events = EventsClient(client_wrapper=self._client_wrapper)
         self.jobs = JobsClient(client_wrapper=self._client_wrapper)
+        self.identity = IdentityClient(client_wrapper=self._client_wrapper)
         self.models = ModelsClient(client_wrapper=self._client_wrapper)
         self.organization = OrganizationClient(client_wrapper=self._client_wrapper)
         self.users = UsersClient(client_wrapper=self._client_wrapper)
         self.permissions = PermissionsClient(client_wrapper=self._client_wrapper)
-        self.model_sync = ModelSyncClient(client_wrapper=self._client_wrapper)
         self.webhooks = WebhooksClient(client_wrapper=self._client_wrapper)
 
 
@@ -88,9 +85,7 @@ class AsyncPolytomic:
 
                                              Defaults to PolytomicEnvironment.DEFAULT
 
-        - x_polytomic_version: typing.Optional[typing.Literal["2023-04-25"]].
-
-        - token: typing.Optional[typing.Union[str, typing.Callable[[], str]]].
+        - token: typing.Union[str, typing.Callable[[], str]].
 
         - timeout: typing.Optional[float]. The timeout to be used, in seconds, for requests by default the timeout is 60 seconds, unless a custom httpx client is used, in which case a default is not set.
 
@@ -99,7 +94,6 @@ class AsyncPolytomic:
     from polytomic.client import AsyncPolytomic
 
     client = AsyncPolytomic(
-        x_polytomic_version="YOUR_X_POLYTOMIC_VERSION",
         token="YOUR_TOKEN",
     )
     """
@@ -109,29 +103,28 @@ def __init__(
         *,
         base_url: typing.Optional[str] = None,
         environment: PolytomicEnvironment = PolytomicEnvironment.DEFAULT,
-        x_polytomic_version: typing.Optional[typing.Literal["2023-04-25"]] = None,
-        token: typing.Optional[typing.Union[str, typing.Callable[[], str]]] = None,
+        token: typing.Union[str, typing.Callable[[], str]],
         timeout: typing.Optional[float] = None,
         httpx_client: typing.Optional[httpx.AsyncClient] = None
     ):
         _defaulted_timeout = timeout if timeout is not None else 60 if httpx_client is None else None
         self._client_wrapper = AsyncClientWrapper(
             base_url=_get_base_url(base_url=base_url, environment=environment),
-            x_polytomic_version=x_polytomic_version,
             token=token,
             httpx_client=httpx.AsyncClient(timeout=_defaulted_timeout) if httpx_client is None else httpx_client,
             timeout=_defaulted_timeout,
         )
         self.bulk_sync = AsyncBulkSyncClient(client_wrapper=self._client_wrapper)
         self.connections = AsyncConnectionsClient(client_wrapper=self._client_wrapper)
+        self.model_sync = AsyncModelSyncClient(client_wrapper=self._client_wrapper)
         self.schemas = AsyncSchemasClient(client_wrapper=self._client_wrapper)
         self.events = AsyncEventsClient(client_wrapper=self._client_wrapper)
         self.jobs = AsyncJobsClient(client_wrapper=self._client_wrapper)
+        self.identity = AsyncIdentityClient(client_wrapper=self._client_wrapper)
         self.models = AsyncModelsClient(client_wrapper=self._client_wrapper)
         self.organization = AsyncOrganizationClient(client_wrapper=self._client_wrapper)
         self.users = AsyncUsersClient(client_wrapper=self._client_wrapper)
         self.permissions = AsyncPermissionsClient(client_wrapper=self._client_wrapper)
-        self.model_sync = AsyncModelSyncClient(client_wrapper=self._client_wrapper)
         self.webhooks = AsyncWebhooksClient(client_wrapper=self._client_wrapper)
 
 

src/polytomic/client.py

@@ -11,12 +11,10 @@ class BaseClientWrapper:
     def __init__(
         self,
         *,
-        x_polytomic_version: typing.Optional[typing.Literal["2023-04-25"]] = None,
-        token: typing.Optional[typing.Union[str, typing.Callable[[], str]]] = None,
+        token: typing.Union[str, typing.Callable[[], str]],
         base_url: str,
         timeout: typing.Optional[float] = None,
     ):
-        self._x_polytomic_version = x_polytomic_version
         self._token = token
         self._base_url = base_url
         self._timeout = timeout
@@ -25,17 +23,14 @@ def get_headers(self) -> typing.Dict[str, str]:
         headers: typing.Dict[str, str] = {
             "X-Fern-Language": "Python",
             "X-Fern-SDK-Name": "polytomic",
-            "X-Fern-SDK-Version": "0.1.2",
+            "X-Fern-SDK-Version": "0.2.0",
         }
-        if self._x_polytomic_version is not None:
-            headers["X-Polytomic-Version"] = self._x_polytomic_version
-        token = self._get_token()
-        if token is not None:
-            headers["Authorization"] = f"Bearer {token}"
+        headers["Authorization"] = f"Bearer {self._get_token()}"
+        headers["X-Polytomic-Version"] = "2024-02-08"
         return headers
 
-    def _get_token(self) -> typing.Optional[str]:
-        if isinstance(self._token, str) or self._token is None:
+    def _get_token(self) -> str:
+        if isinstance(self._token, str):
             return self._token
         else:
             return self._token()
@@ -51,25 +46,23 @@ class SyncClientWrapper(BaseClientWrapper):
     def __init__(
         self,
         *,
-        x_polytomic_version: typing.Optional[typing.Literal["2023-04-25"]] = None,
-        token: typing.Optional[typing.Union[str, typing.Callable[[], str]]] = None,
+        token: typing.Union[str, typing.Callable[[], str]],
         base_url: str,
         timeout: typing.Optional[float] = None,
         httpx_client: httpx.Client,
     ):
-        super().__init__(x_polytomic_version=x_polytomic_version, token=token, base_url=base_url, timeout=timeout)
+        super().__init__(token=token, base_url=base_url, timeout=timeout)
         self.httpx_client = HttpClient(httpx_client=httpx_client)
 
 
 class AsyncClientWrapper(BaseClientWrapper):
     def __init__(
         self,
         *,
-        x_polytomic_version: typing.Optional[typing.Literal["2023-04-25"]] = None,
-        token: typing.Optional[typing.Union[str, typing.Callable[[], str]]] = None,
+        token: typing.Union[str, typing.Callable[[], str]],
         base_url: str,
         timeout: typing.Optional[float] = None,
         httpx_client: httpx.AsyncClient,
     ):
-        super().__init__(x_polytomic_version=x_polytomic_version, token=token, base_url=base_url, timeout=timeout)
+        super().__init__(token=token, base_url=base_url, timeout=timeout)
         self.httpx_client = AsyncHttpClient(httpx_client=httpx_client)

src/polytomic/core/client_wrapper.py

@@ -1,5 +1,17 @@
 # This file was auto-generated by Fern from our API Definition.
 
+from .bad_request_error import BadRequestError
+from .forbidden_error import ForbiddenError
+from .internal_server_error import InternalServerError
+from .not_found_error import NotFoundError
 from .unauthorized_error import UnauthorizedError
+from .unprocessable_entity_error import UnprocessableEntityError
 
-__all__ = ["UnauthorizedError"]
+__all__ = [
+    "BadRequestError",
+    "ForbiddenError",
+    "InternalServerError",
+    "NotFoundError",
+    "UnauthorizedError",
+    "UnprocessableEntityError",
+]

src/polytomic/errors/__init__.py

@@ -0,0 +1,9 @@
+# This file was auto-generated from our API Definition.
+
+from ..core.api_error import ApiError as core_api_error_ApiError
+from ..types.api_error import ApiError as types_api_error_ApiError
+
+
+class BadRequestError(core_api_error_ApiError):
+    def __init__(self, body: types_api_error_ApiError):
+        super().__init__(status_code=400, body=body)

src/polytomic/errors/bad_request_error.py

@@ -0,0 +1,9 @@
+# This file was auto-generated from our API Definition.
+
+from ..core.api_error import ApiError as core_api_error_ApiError
+from ..types.api_error import ApiError as types_api_error_ApiError
+
+
+class ForbiddenError(core_api_error_ApiError):
+    def __init__(self, body: types_api_error_ApiError):
+        super().__init__(status_code=403, body=body)

src/polytomic/errors/forbidden_error.py

@@ -0,0 +1,9 @@
+# This file was auto-generated from our API Definition.
+
+from ..core.api_error import ApiError as core_api_error_ApiError
+from ..types.api_error import ApiError as types_api_error_ApiError
+
+
+class InternalServerError(core_api_error_ApiError):
+    def __init__(self, body: types_api_error_ApiError):
+        super().__init__(status_code=500, body=body)