Merge pull request #841 from atlanhq/BLDX-715

BLDX-715 | Regenerate v9 models with validate/minimize/relate SDK methods

Author: Aryamanz29

pyatlan_v9/model/assets/adf.py

@@ -25,6 +25,7 @@
 from pyatlan_v9.model.serde import Serde, get_serde
 from pyatlan_v9.model.transform import register_asset
 
+from .adf_related import RelatedADF
 from .airflow_related import RelatedAirflowTask
 from .anomalo_related import RelatedAnomaloCheck
 from .app_related import RelatedApplication, RelatedApplicationField
@@ -193,6 +194,66 @@ class ADF(Asset):
     def __post_init__(self) -> None:
         self.type_name = "ADF"
 
+    # =========================================================================
+    # SDK Methods
+    # =========================================================================
+
+    def validate(self, for_creation: bool = False) -> None:
+        """
+        Dry-run validation of this ADF instance.
+
+        Checks that required fields (type_name, name, qualified_name) are set.
+        When ``for_creation=True``, also checks hierarchy-specific fields
+        (parent references, denormalized attributes) needed to create this asset.
+
+        This is purely opt-in and is NOT called by any serde path — only by
+        explicit user invocation (e.g., validating JSONL before sending to Atlan).
+
+        Args:
+            for_creation: If True, also validate fields required for asset creation.
+
+        Raises:
+            ValueError: If any required fields are missing or invalid.
+        """
+        errors: list[str] = []
+        if self.type_name is UNSET:
+            errors.append("type_name is required")
+        if self.name is UNSET:
+            errors.append("name is required")
+        if self.qualified_name is UNSET or self.qualified_name is None:
+            errors.append("qualified_name is required")
+        if errors:
+            raise ValueError(f"ADF validation failed: {errors}")
+
+    def minimize(self) -> "ADF":
+        """
+        Return a minimal copy of this ADF with only updater-required fields.
+
+        Calls :meth:`validate` first to ensure the instance is valid, then
+        returns a new ADF with only the fields needed for an update
+        (qualified_name, name, and any type-specific additional fields).
+
+        Returns:
+            A new ADF instance with only the minimum required fields.
+        """
+        self.validate()
+        return ADF(qualified_name=self.qualified_name, name=self.name)
+
+    def relate(self) -> "RelatedADF":
+        """
+        Create a :class:`RelatedADF` reference from this instance.
+
+        Returns a lightweight reference suitable for use in relationship
+        attributes. Prefers ``guid`` if set, otherwise falls back to
+        ``qualified_name``.
+
+        Returns:
+            A RelatedADF reference to this asset.
+        """
+        if self.guid is not UNSET:
+            return RelatedADF(guid=self.guid)
+        return RelatedADF(qualified_name=self.qualified_name)
+
     # =========================================================================
     # Optimized Serialization Methods (override Asset base class)
     # =========================================================================

pyatlan_v9/model/assets/adf_activity.py

@@ -27,6 +27,7 @@
 from pyatlan_v9.model.transform import register_asset
 
 from .adf_related import (
+    RelatedAdfActivity,
     RelatedAdfDataflow,
     RelatedAdfDataset,
     RelatedAdfLinkedservice,
@@ -302,6 +303,74 @@ def __post_init__(self) -> None:
 
     _QUALIFIED_NAME_PATTERN: ClassVar[re.Pattern] = re.compile(r"^.+/[^/]+/[^/]+$")
 
+    def validate(self, for_creation: bool = False) -> None:
+        """
+        Dry-run validation of this AdfActivity instance.
+
+        Checks that required fields (type_name, name, qualified_name) are set.
+        When ``for_creation=True``, also checks hierarchy-specific fields
+        (parent references, denormalized attributes) needed to create this asset.
+
+        This is purely opt-in and is NOT called by any serde path — only by
+        explicit user invocation (e.g., validating JSONL before sending to Atlan).
+
+        Args:
+            for_creation: If True, also validate fields required for asset creation.
+
+        Raises:
+            ValueError: If any required fields are missing or invalid.
+        """
+        errors: list[str] = []
+        if self.type_name is UNSET:
+            errors.append("type_name is required")
+        if self.name is UNSET:
+            errors.append("name is required")
+        if self.qualified_name is UNSET or self.qualified_name is None:
+            errors.append("qualified_name is required")
+        elif not self._QUALIFIED_NAME_PATTERN.match(self.qualified_name):
+            errors.append(
+                f"qualified_name '{self.qualified_name}' does not match expected "
+                f"pattern: {self._QUALIFIED_NAME_PATTERN.pattern}"
+            )
+        if for_creation:
+            if self.connection_qualified_name is UNSET:
+                errors.append("connection_qualified_name is required for creation")
+            if self.adf_pipeline is UNSET:
+                errors.append("adf_pipeline is required for creation")
+            if self.adf_pipeline_qualified_name is UNSET:
+                errors.append("adf_pipeline_qualified_name is required for creation")
+        if errors:
+            raise ValueError(f"AdfActivity validation failed: {errors}")
+
+    def minimize(self) -> "AdfActivity":
+        """
+        Return a minimal copy of this AdfActivity with only updater-required fields.
+
+        Calls :meth:`validate` first to ensure the instance is valid, then
+        returns a new AdfActivity with only the fields needed for an update
+        (qualified_name, name, and any type-specific additional fields).
+
+        Returns:
+            A new AdfActivity instance with only the minimum required fields.
+        """
+        self.validate()
+        return AdfActivity(qualified_name=self.qualified_name, name=self.name)
+
+    def relate(self) -> "RelatedAdfActivity":
+        """
+        Create a :class:`RelatedAdfActivity` reference from this instance.
+
+        Returns a lightweight reference suitable for use in relationship
+        attributes. Prefers ``guid`` if set, otherwise falls back to
+        ``qualified_name``.
+
+        Returns:
+            A RelatedAdfActivity reference to this asset.
+        """
+        if self.guid is not UNSET:
+            return RelatedAdfActivity(guid=self.guid)
+        return RelatedAdfActivity(qualified_name=self.qualified_name)
+
     # =========================================================================
     # Optimized Serialization Methods (override Asset base class)
     # =========================================================================

pyatlan_v9/model/assets/adf_dataflow.py

@@ -27,6 +27,7 @@
 
 from .adf_related import (
     RelatedAdfActivity,
+    RelatedAdfDataflow,
     RelatedAdfDataset,
     RelatedAdfLinkedservice,
     RelatedAdfPipeline,
@@ -227,6 +228,66 @@ class AdfDataflow(Asset):
     def __post_init__(self) -> None:
         self.type_name = "AdfDataflow"
 
+    # =========================================================================
+    # SDK Methods
+    # =========================================================================
+
+    def validate(self, for_creation: bool = False) -> None:
+        """
+        Dry-run validation of this AdfDataflow instance.
+
+        Checks that required fields (type_name, name, qualified_name) are set.
+        When ``for_creation=True``, also checks hierarchy-specific fields
+        (parent references, denormalized attributes) needed to create this asset.
+
+        This is purely opt-in and is NOT called by any serde path — only by
+        explicit user invocation (e.g., validating JSONL before sending to Atlan).
+
+        Args:
+            for_creation: If True, also validate fields required for asset creation.
+
+        Raises:
+            ValueError: If any required fields are missing or invalid.
+        """
+        errors: list[str] = []
+        if self.type_name is UNSET:
+            errors.append("type_name is required")
+        if self.name is UNSET:
+            errors.append("name is required")
+        if self.qualified_name is UNSET or self.qualified_name is None:
+            errors.append("qualified_name is required")
+        if errors:
+            raise ValueError(f"AdfDataflow validation failed: {errors}")
+
+    def minimize(self) -> "AdfDataflow":
+        """
+        Return a minimal copy of this AdfDataflow with only updater-required fields.
+
+        Calls :meth:`validate` first to ensure the instance is valid, then
+        returns a new AdfDataflow with only the fields needed for an update
+        (qualified_name, name, and any type-specific additional fields).
+
+        Returns:
+            A new AdfDataflow instance with only the minimum required fields.
+        """
+        self.validate()
+        return AdfDataflow(qualified_name=self.qualified_name, name=self.name)
+
+    def relate(self) -> "RelatedAdfDataflow":
+        """
+        Create a :class:`RelatedAdfDataflow` reference from this instance.
+
+        Returns a lightweight reference suitable for use in relationship
+        attributes. Prefers ``guid`` if set, otherwise falls back to
+        ``qualified_name``.
+
+        Returns:
+            A RelatedAdfDataflow reference to this asset.
+        """
+        if self.guid is not UNSET:
+            return RelatedAdfDataflow(guid=self.guid)
+        return RelatedAdfDataflow(qualified_name=self.qualified_name)
+
     # =========================================================================
     # Optimized Serialization Methods (override Asset base class)
     # =========================================================================

pyatlan_v9/model/assets/adf_dataset.py

@@ -28,6 +28,7 @@
 from .adf_related import (
     RelatedAdfActivity,
     RelatedAdfDataflow,
+    RelatedAdfDataset,
     RelatedAdfLinkedservice,
     RelatedAdfPipeline,
 )
@@ -259,6 +260,66 @@ class AdfDataset(Asset):
     def __post_init__(self) -> None:
         self.type_name = "AdfDataset"
 
+    # =========================================================================
+    # SDK Methods
+    # =========================================================================
+
+    def validate(self, for_creation: bool = False) -> None:
+        """
+        Dry-run validation of this AdfDataset instance.
+
+        Checks that required fields (type_name, name, qualified_name) are set.
+        When ``for_creation=True``, also checks hierarchy-specific fields
+        (parent references, denormalized attributes) needed to create this asset.
+
+        This is purely opt-in and is NOT called by any serde path — only by
+        explicit user invocation (e.g., validating JSONL before sending to Atlan).
+
+        Args:
+            for_creation: If True, also validate fields required for asset creation.
+
+        Raises:
+            ValueError: If any required fields are missing or invalid.
+        """
+        errors: list[str] = []
+        if self.type_name is UNSET:
+            errors.append("type_name is required")
+        if self.name is UNSET:
+            errors.append("name is required")
+        if self.qualified_name is UNSET or self.qualified_name is None:
+            errors.append("qualified_name is required")
+        if errors:
+            raise ValueError(f"AdfDataset validation failed: {errors}")
+
+    def minimize(self) -> "AdfDataset":
+        """
+        Return a minimal copy of this AdfDataset with only updater-required fields.
+
+        Calls :meth:`validate` first to ensure the instance is valid, then
+        returns a new AdfDataset with only the fields needed for an update
+        (qualified_name, name, and any type-specific additional fields).
+
+        Returns:
+            A new AdfDataset instance with only the minimum required fields.
+        """
+        self.validate()
+        return AdfDataset(qualified_name=self.qualified_name, name=self.name)
+
+    def relate(self) -> "RelatedAdfDataset":
+        """
+        Create a :class:`RelatedAdfDataset` reference from this instance.
+
+        Returns a lightweight reference suitable for use in relationship
+        attributes. Prefers ``guid`` if set, otherwise falls back to
+        ``qualified_name``.
+
+        Returns:
+            A RelatedAdfDataset reference to this asset.
+        """
+        if self.guid is not UNSET:
+            return RelatedAdfDataset(guid=self.guid)
+        return RelatedAdfDataset(qualified_name=self.qualified_name)
+
     # =========================================================================
     # Optimized Serialization Methods (override Asset base class)
     # =========================================================================

pyatlan_v9/model/assets/adf_linkedservice.py

@@ -29,6 +29,7 @@
     RelatedAdfActivity,
     RelatedAdfDataflow,
     RelatedAdfDataset,
+    RelatedAdfLinkedservice,
     RelatedAdfPipeline,
 )
 from .airflow_related import RelatedAirflowTask
@@ -275,6 +276,66 @@ class AdfLinkedservice(Asset):
     def __post_init__(self) -> None:
         self.type_name = "AdfLinkedservice"
 
+    # =========================================================================
+    # SDK Methods
+    # =========================================================================
+
+    def validate(self, for_creation: bool = False) -> None:
+        """
+        Dry-run validation of this AdfLinkedservice instance.
+
+        Checks that required fields (type_name, name, qualified_name) are set.
+        When ``for_creation=True``, also checks hierarchy-specific fields
+        (parent references, denormalized attributes) needed to create this asset.
+
+        This is purely opt-in and is NOT called by any serde path — only by
+        explicit user invocation (e.g., validating JSONL before sending to Atlan).
+
+        Args:
+            for_creation: If True, also validate fields required for asset creation.
+
+        Raises:
+            ValueError: If any required fields are missing or invalid.
+        """
+        errors: list[str] = []
+        if self.type_name is UNSET:
+            errors.append("type_name is required")
+        if self.name is UNSET:
+            errors.append("name is required")
+        if self.qualified_name is UNSET or self.qualified_name is None:
+            errors.append("qualified_name is required")
+        if errors:
+            raise ValueError(f"AdfLinkedservice validation failed: {errors}")
+
+    def minimize(self) -> "AdfLinkedservice":
+        """
+        Return a minimal copy of this AdfLinkedservice with only updater-required fields.
+
+        Calls :meth:`validate` first to ensure the instance is valid, then
+        returns a new AdfLinkedservice with only the fields needed for an update
+        (qualified_name, name, and any type-specific additional fields).
+
+        Returns:
+            A new AdfLinkedservice instance with only the minimum required fields.
+        """
+        self.validate()
+        return AdfLinkedservice(qualified_name=self.qualified_name, name=self.name)
+
+    def relate(self) -> "RelatedAdfLinkedservice":
+        """
+        Create a :class:`RelatedAdfLinkedservice` reference from this instance.
+
+        Returns a lightweight reference suitable for use in relationship
+        attributes. Prefers ``guid`` if set, otherwise falls back to
+        ``qualified_name``.
+
+        Returns:
+            A RelatedAdfLinkedservice reference to this asset.
+        """
+        if self.guid is not UNSET:
+            return RelatedAdfLinkedservice(guid=self.guid)
+        return RelatedAdfLinkedservice(qualified_name=self.qualified_name)
+
     # =========================================================================
     # Optimized Serialization Methods (override Asset base class)
     # =========================================================================