Remove custom pyatlan/validate.py, switch legacy code to pydantic v1 validate_arguments

Delete the custom validate_arguments wrapper and _is_model_instance utility.
All legacy client, model, and UI code now uses pydantic.v1's validate_arguments
directly. Also removes the msgspec cross-type encoder registration from model/core.py
and _is_msgspec_cross_type_match from utils.py, and updates the batch __track method
to support v9 models via getattr type_name check.

Made-with: Cursor

Author: Aryamanz29

pyatlan/client/admin.py

@@ -1,6 +1,8 @@
 # SPDX-License-Identifier: Apache-2.0
 # Copyright 2025 Atlan Pte. Ltd.
 
+from pydantic.v1 import validate_arguments
+
 from pyatlan.client.common import AdminGetAdminEvents, AdminGetKeycloakEvents, ApiCaller
 from pyatlan.errors import ErrorCode
 from pyatlan.model.keycloak_events import (
@@ -9,7 +11,6 @@
     KeycloakEventRequest,
     KeycloakEventResponse,
 )
-from pyatlan.validate import validate_arguments
 
 
 class AdminClient:

pyatlan/client/aio/admin.py

@@ -1,6 +1,8 @@
 # SPDX-License-Identifier: Apache-2.0
 # Copyright 2025 Atlan Pte. Ltd.
 
+from pydantic.v1 import validate_arguments
+
 from pyatlan.client.common import (
     AdminGetAdminEvents,
     AdminGetKeycloakEvents,
@@ -12,7 +14,6 @@
     AsyncKeycloakEventResponse,
 )
 from pyatlan.model.keycloak_events import AdminEventRequest, KeycloakEventRequest
-from pyatlan.validate import validate_arguments
 
 
 class AsyncAdminClient:

pyatlan/client/aio/asset.py

@@ -17,7 +17,7 @@
     overload,
 )
 
-from pydantic.v1 import StrictStr, constr
+from pydantic.v1 import StrictStr, constr, validate_arguments
 from tenacity import (
     retry,
     retry_if_exception_type,
@@ -84,7 +84,6 @@
 from pyatlan.model.fields.atlan_fields import AtlanField
 from pyatlan.model.response import AssetMutationResponse
 from pyatlan.model.search import IndexSearchRequest, Query
-from pyatlan.validate import validate_arguments
 
 if TYPE_CHECKING:
     from pyatlan.model.search import IndexSearchRequest

pyatlan/client/aio/audit.py

@@ -4,11 +4,12 @@
 
 import logging
 
+from pydantic.v1 import validate_arguments
+
 from pyatlan.client.common import AsyncApiCaller, AuditSearch
 from pyatlan.errors import ErrorCode
 from pyatlan.model.aio.audit import AsyncAuditSearchResults
 from pyatlan.model.audit import AuditSearchRequest
-from pyatlan.validate import validate_arguments
 
 LOGGER = logging.getLogger(__name__)
 

pyatlan/client/aio/batch.py

@@ -4,6 +4,8 @@
 
 from typing import TYPE_CHECKING, Dict, List, Optional, cast
 
+from pydantic.v1 import validate_arguments
+
 from pyatlan.client.asset import (
     AssetCreationHandling,
     AssetIdentity,
@@ -15,7 +17,6 @@
 from pyatlan.model.fluent_search import FluentSearch
 from pyatlan.model.response import AssetMutationResponse
 from pyatlan.model.search import DSL
-from pyatlan.validate import _is_model_instance, validate_arguments
 
 if TYPE_CHECKING:
     from pyatlan.client.aio.client import AsyncAtlanClient
@@ -409,10 +410,11 @@ def _track_response(self, response: AssetMutationResponse, sent: list[Asset]):
 
     @staticmethod
     def __track(tracker: List[Asset], candidate: Asset):
-        if _is_model_instance(candidate, AtlasGlossaryTerm):
-            # trim_to_required for AtlasGlossaryTerm requires anchor
-            # which is not include in AssetMutationResponse
-            asset = cast(Asset, AtlasGlossaryTerm.ref_by_guid(candidate.guid))
+        if (
+            isinstance(candidate, AtlasGlossaryTerm)
+            or getattr(candidate, "type_name", None) == "AtlasGlossaryTerm"
+        ):
+            asset = cast(Asset, type(candidate).ref_by_guid(candidate.guid))
         else:
             asset = candidate.trim_to_required()
         asset.name = candidate.name

pyatlan/client/aio/contract.py

@@ -4,11 +4,12 @@
 
 from typing import Optional
 
+from pydantic.v1 import validate_arguments
+
 from pyatlan.client.common import AsyncApiCaller, ContractInit
 from pyatlan.client.constants import CONTRACT_INIT_API
 from pyatlan.errors import ErrorCode
 from pyatlan.model.assets import Asset
-from pyatlan.validate import validate_arguments
 
 
 class AsyncContractClient:

pyatlan/client/aio/credential.py

@@ -4,6 +4,8 @@
 
 from typing import TYPE_CHECKING, Any, Dict, Optional
 
+from pydantic.v1 import validate_arguments
+
 from pyatlan.client.common import (
     AsyncApiCaller,
     CredentialCreate,
@@ -21,7 +23,6 @@
     CredentialResponse,
     CredentialTestResponse,
 )
-from pyatlan.validate import validate_arguments
 
 if TYPE_CHECKING:
     pass

pyatlan/client/aio/file.py

@@ -2,6 +2,8 @@
 # Copyright 2025 Atlan Pte. Ltd.
 from __future__ import annotations
 
+from pydantic.v1 import validate_arguments
+
 from pyatlan.client.common import (
     AsyncApiCaller,
     FileDownload,
@@ -10,7 +12,6 @@
 )
 from pyatlan.errors import ErrorCode
 from pyatlan.model.file import PresignedURLRequest
-from pyatlan.validate import validate_arguments
 
 
 class AsyncFileClient:

pyatlan/client/aio/group.py

@@ -4,7 +4,7 @@
 
 from typing import List, Optional
 
-from pydantic.v1 import parse_obj_as
+from pydantic.v1 import parse_obj_as, validate_arguments
 
 from pyatlan.client.common import (
     AsyncApiCaller,
@@ -20,7 +20,6 @@
 from pyatlan.model.aio.user import AsyncUserResponse
 from pyatlan.model.group import AtlanGroup, CreateGroupResponse
 from pyatlan.model.user import UserRequest
-from pyatlan.validate import validate_arguments
 
 
 class AsyncGroupClient:

pyatlan/client/aio/oauth_client.py

@@ -5,6 +5,8 @@
 
 from typing import List, Optional
 
+from pydantic.v1 import validate_arguments
+
 from pyatlan.client.common import (
     AsyncApiCaller,
     OAuthClientCreate,
@@ -17,7 +19,6 @@
 from pyatlan.errors import ErrorCode
 from pyatlan.model.aio.oauth_client import AsyncOAuthClientListResponse
 from pyatlan.model.oauth_client import OAuthClientCreateResponse, OAuthClientResponse
-from pyatlan.validate import validate_arguments
 
 
 class AsyncOAuthClient: