[feat] Migrate v9 models and tests: events, packages, open lineage, DQ rules, lineage

- pyatlan_v9/model/events.py: Full v9 migration with AtlanEvent.from_dict()
  for polymorphic Asset dispatch via type registry and payload discrimination
- pyatlan_v9/model/packages/: Migrate AbstractPackage, crawlers, miners to msgspec
- pyatlan_v9/model/open_lineage/: All OpenLineage models as msgspec.Struct
- pyatlan_v9/model/assets/data_quality_rule.py: Creator/updater methods, static helpers
- pyatlan_v9/model/assets/asset.py: remove_description/user_description/owners, ClassVar descriptors
- pyatlan_v9/model/workflow.py: rename=camel, to_json()
- pyatlan_v9/model/credential.py: rename=camel
- pyatlan_v9/model/lineage.py: rename=camel, validate_arguments
- pyatlan_v9/client/atlan.py: msgspec.Struct handling in _create_params, parse_query, upload_image
- tests_v9/unit/: Update all v9 tests to use v9 models and client exclusively
- tests_v9/unit/test_events.py: Uses v9 AtlanEvent.from_dict(), no legacy imports
- tests_v9/unit/test_lineage.py, test_model.py: New, ported from legacy

Author: Aryamanz29

pyatlan_v9/client/atlan.py

@@ -53,10 +53,8 @@
 from pyatlan.client.user import UserClient
 from pyatlan.client.workflow import WorkflowClient
 from pyatlan.errors import ERROR_CODE_FOR_HTTP_STATUS, AtlanError, ErrorCode
-from pyatlan.model.atlan_image import AtlanImage
 from pyatlan.model.core import AtlanObject, AtlanRequest, AtlanResponse
 from pyatlan.model.enums import AtlanTypeCategory
-from pyatlan.model.query import ParsedQuery, QueryParserRequest
 from pyatlan.multipart_data_generator import MultipartDataGenerator
 from pyatlan.utils import (
     API,
@@ -66,6 +64,8 @@
     get_python_version,
 )
 from pyatlan_v9.client.transport import PyatlanSyncTransport
+from pyatlan_v9.model.atlan_image import AtlanImage
+from pyatlan_v9.model.query import ParsedQuery, QueryParserRequest
 
 request_id_var = ContextVar("request_id", default=None)
 
@@ -657,6 +657,8 @@ def _create_params(
                 params["data"] = AtlanRequest(instance=request_obj, client=self).json()
             elif api.consumes == APPLICATION_ENCODED_FORM:
                 params["data"] = request_obj
+            elif isinstance(request_obj, msgspec.Struct):
+                params["data"] = msgspec.json.encode(request_obj)
             else:
                 params["data"] = json.dumps(request_obj)
         return params
@@ -736,7 +738,7 @@ def upload_image(self, file, filename: str) -> AtlanImage:
         :raises AtlanError: on any API communication issue
         """
         raw_json = self._upload_file(UPLOAD_IMAGE, file=file, filename=filename)
-        return AtlanImage(**raw_json)
+        return msgspec.convert(raw_json, AtlanImage, strict=False)
 
     def parse_query(self, query: QueryParserRequest) -> Optional[ParsedQuery]:
         """
@@ -751,7 +753,7 @@ def parse_query(self, query: QueryParserRequest) -> Optional[ParsedQuery]:
             request_obj=query,
             exclude_unset=True,
         )
-        return ParsedQuery(**raw_json)
+        return msgspec.convert(raw_json, ParsedQuery, strict=False)
 
     @contextlib.contextmanager
     def max_retries(

pyatlan_v9/model/assets/asset.py

@@ -50,6 +50,9 @@ class Asset(Referenceable):
     DISPLAY_NAME: ClassVar = None  # Initialized after imports below
     CONNECTOR_NAME: ClassVar = None  # Initialized after imports below
     CONNECTION_NAME: ClassVar = None  # Initialized after imports below
+    ASSET_DQ_ROW_SCOPE_FILTER_COLUMN_QUALIFIED_NAME: ClassVar = (
+        None  # Initialized after imports below
+    )
 
     # =========================================================================
     # Instance Fields
@@ -743,6 +746,37 @@ def remove_certificate(self) -> "Asset":
         self.certificate_status_message = None
         return self
 
+    def remove_description(self) -> "Asset":
+        """
+        Remove the description from this asset.
+
+        Returns:
+            Self for fluent chaining
+        """
+        self.description = None
+        return self
+
+    def remove_user_description(self) -> "Asset":
+        """
+        Remove the user description from this asset.
+
+        Returns:
+            Self for fluent chaining
+        """
+        self.user_description = None
+        return self
+
+    def remove_owners(self) -> "Asset":
+        """
+        Remove the owners from this asset.
+
+        Returns:
+            Self for fluent chaining
+        """
+        self.owner_groups = None
+        self.owner_users = None
+        return self
+
     def flush_custom_metadata(self, client=None) -> None:
         """
         Flush (clear) all custom metadata on this asset.
@@ -816,6 +850,8 @@ def trim_to_required(self) -> "Asset":
     KeywordField,
     KeywordTextField,
     KeywordTextStemmedField,
+    NumericField,
+    TextField,
 )
 
 Asset.NAME = KeywordTextStemmedField("name", "name.keyword", "name", "name.stemmed")
@@ -826,6 +862,32 @@ def trim_to_required(self) -> "Asset":
 Asset.CONNECTION_NAME = KeywordTextField(
     "connectionName", "connectionName", "connectionName.text"
 )
+Asset.DESCRIPTION = KeywordTextField(
+    "description", "description.keyword", "description.text"
+)
+Asset.USER_DESCRIPTION = KeywordTextField(
+    "userDescription", "userDescription.keyword", "userDescription.text"
+)
+Asset.CERTIFICATE_STATUS = KeywordTextField(
+    "certificateStatus", "certificateStatus", "certificateStatus.text"
+)
+Asset.CERTIFICATE_STATUS_MESSAGE = TextField(
+    "certificateStatusMessage", "certificateStatusMessage"
+)
+Asset.ANNOUNCEMENT_TITLE = TextField("announcementTitle", "announcementTitle")
+Asset.ANNOUNCEMENT_MESSAGE = TextField("announcementMessage", "announcementMessage")
+Asset.ANNOUNCEMENT_TYPE = KeywordField("announcementType", "announcementType")
+Asset.ANNOUNCEMENT_UPDATED_AT = NumericField(
+    "announcementUpdatedAt", "announcementUpdatedAt"
+)
+Asset.OWNER_USERS = KeywordField("ownerUsers", "ownerUsers")
+Asset.OWNER_GROUPS = KeywordField("ownerGroups", "ownerGroups")
+Asset.ADMIN_USERS = KeywordField("adminUsers", "adminUsers")
+Asset.ADMIN_GROUPS = KeywordField("adminGroups", "adminGroups")
+Asset.ASSET_DQ_ROW_SCOPE_FILTER_COLUMN_QUALIFIED_NAME = KeywordField(
+    "assetDQRowScopeFilterColumnQualifiedName",
+    "assetDQRowScopeFilterColumnQualifiedName",
+)
 
 
 # =============================================================================

pyatlan_v9/model/assets/connection.py

@@ -206,17 +206,20 @@ def creator(
         client.role_cache.validate_idstrs(idstrs=admin_roles or [])
         client.group_cache.validate_aliases(aliases=admin_groups or [])
 
-        return cls(
+        kwargs: dict = dict(
             name=name,
             qualified_name=connector_type.to_qualified_name(),
             connector_name=connector_type.value,
             category=connector_type.category.value,
             admin_users=set() if admin_users is None else set(admin_users),
             admin_groups=set() if admin_groups is None else set(admin_groups),
             admin_roles=set() if admin_roles is None else set(admin_roles),
-            host=host,
-            port=port,
         )
+        if host is not None:
+            kwargs["host"] = host
+        if port is not None:
+            kwargs["port"] = port
+        return cls(**kwargs)
 
     @classmethod
     def updater(cls, *, qualified_name: str, name: str) -> "Connection":