Merge pull request #644 from atlanhq/bump-to-release-6.2.0

[release] Bump to release `6.2.0`

Author: Aryamanz29

HISTORY.md

@@ -1,3 +1,23 @@
+## 6.2.0 (May 27, 2025)
+
+### New Features
+
+- Added support for `append_atlan_tags` in the `AssetClient.save()` method.
+- Introduced `AssetClient.remove_atlan_tags()` to allow users to remove one or more Atlan tags from a given asset.
+- Enhanced the SDK to use the `/bulk` endpoint for all tag mutation operations.
+
+### Breaking Changes
+
+- All tag mutation methods (`add_atlan_tags`, `update_atlan_tags`, `remove_atlan_tag`, `remove_atlan_tags`) now use the `/bulk` endpoint. As a result, these methods will now return an `AssetMutationResponse` instead of `None`, reflecting the updated API response structure.
+
+### Bug Fixes
+
+- Added default `typeName=Referenceable` to `Bool`(must) clauses when `typeName` is not explicitly provided in the search request. This ensures the SDK retrieves only assets that inherit from the `Referenceable` supertype.
+
+### QOL Improvements
+
+- Regenerated the latest typedef models.
+
 ## 6.1.1 (May 21, 2025)
 
 ### New Features

docs/asset/tableaudashboardfield.rst

@@ -0,0 +1,10 @@
+.. _tableaudashboardfield:
+
+TableauDashboardField
+=====================
+
+.. module:: pyatlan.model.assets
+    :no-index:
+
+.. autoclass:: TableauDashboardField
+    :members:

docs/asset/tableauworksheetfield.rst

@@ -0,0 +1,10 @@
+.. _tableauworksheetfield:
+
+TableauWorksheetField
+=====================
+
+.. module:: pyatlan.model.assets
+    :no-index:
+
+.. autoclass:: TableauWorksheetField
+    :members:

docs/assets.rst

@@ -323,6 +323,7 @@ You can interact with all of the following different kinds of assets:
     asset/tableau
     asset/tableaucalculatedfield
     asset/tableaudashboard
+    asset/tableaudashboardfield
     asset/tableaudatasource
     asset/tableaudatasourcefield
     asset/tableauflow
@@ -331,6 +332,7 @@ You can interact with all of the following different kinds of assets:
     asset/tableausite
     asset/tableauworkbook
     asset/tableauworksheet
+    asset/tableauworksheetfield
     asset/tag
     asset/tagattachment
     asset/task

pyatlan/model/assets/__init__.py

@@ -76,8 +76,8 @@
         "SnowflakeStage",
         "SnowflakeStream",
         "DatabricksUnityCatalogTag",
-        "Database",
         "CalculationView",
+        "Database",
         "Procedure",
         "SnowflakeTag",
         "MatillionGroup",
@@ -233,9 +233,11 @@
     "anaplan_dimension": ["AnaplanDimension"],
     "anaplan_view": ["AnaplanView"],
     "tableau_workbook": ["TableauWorkbook"],
+    "tableau_worksheet_field": ["TableauWorksheetField"],
     "tableau_datasource_field": ["TableauDatasourceField"],
     "tableau_calculated_field": ["TableauCalculatedField"],
     "tableau_project": ["TableauProject"],
+    "tableau_dashboard_field": ["TableauDashboardField"],
     "tableau_metric": ["TableauMetric"],
     "tableau_site": ["TableauSite"],
     "tableau_datasource": ["TableauDatasource"],

pyatlan/model/assets/__init__.pyi

@@ -73,8 +73,8 @@ __all__ = [
     "SnowflakeStage",
     "SnowflakeStream",
     "DatabricksUnityCatalogTag",
-    "Database",
     "CalculationView",
+    "Database",
     "Procedure",
     "SnowflakeTag",
     "MatillionGroup",
@@ -230,9 +230,11 @@ __all__ = [
     "AnaplanDimension",
     "AnaplanView",
     "TableauWorkbook",
+    "TableauWorksheetField",
     "TableauDatasourceField",
     "TableauCalculatedField",
     "TableauProject",
+    "TableauDashboardField",
     "TableauMetric",
     "TableauSite",
     "TableauDatasource",
@@ -658,6 +660,7 @@ from .superset_dataset import SupersetDataset
 from .tableau import Tableau
 from .tableau_calculated_field import TableauCalculatedField
 from .tableau_dashboard import TableauDashboard
+from .tableau_dashboard_field import TableauDashboardField
 from .tableau_datasource import TableauDatasource
 from .tableau_datasource_field import TableauDatasourceField
 from .tableau_flow import TableauFlow
@@ -666,6 +669,7 @@ from .tableau_project import TableauProject
 from .tableau_site import TableauSite
 from .tableau_workbook import TableauWorkbook
 from .tableau_worksheet import TableauWorksheet
+from .tableau_worksheet_field import TableauWorksheetField
 from .tag_attachment import TagAttachment
 from .task import Task
 from .thoughtspot import Thoughtspot

pyatlan/model/assets/a_d_l_s.py

@@ -8,17 +8,13 @@
 
 from pydantic.v1 import Field, validator
 
-from pyatlan.model.fields.atlan_fields import (
-    KeywordField,
-    KeywordTextField,
-    RelationField,
-)
+from pyatlan.model.fields.atlan_fields import KeywordField, KeywordTextField
 from pyatlan.model.structs import AzureTag
 
-from .azure import Azure
+from .object_store import ObjectStore
 
 
-class ADLS(Azure):
+class ADLS(ObjectStore):
     """Description"""
 
     type_name: str = Field(default="ADLS", allow_mutation=False)
@@ -71,66 +67,13 @@ def __setattr__(self, name, value):
     Tags that have been applied to this asset in Azure.
     """
 
-    INPUT_TO_SPARK_JOBS: ClassVar[RelationField] = RelationField("inputToSparkJobs")
-    """
-    TBC
-    """
-    INPUT_TO_AIRFLOW_TASKS: ClassVar[RelationField] = RelationField(
-        "inputToAirflowTasks"
-    )
-    """
-    TBC
-    """
-    INPUT_TO_PROCESSES: ClassVar[RelationField] = RelationField("inputToProcesses")
-    """
-    TBC
-    """
-    MODEL_IMPLEMENTED_ATTRIBUTES: ClassVar[RelationField] = RelationField(
-        "modelImplementedAttributes"
-    )
-    """
-    TBC
-    """
-    OUTPUT_FROM_AIRFLOW_TASKS: ClassVar[RelationField] = RelationField(
-        "outputFromAirflowTasks"
-    )
-    """
-    TBC
-    """
-    OUTPUT_FROM_SPARK_JOBS: ClassVar[RelationField] = RelationField(
-        "outputFromSparkJobs"
-    )
-    """
-    TBC
-    """
-    MODEL_IMPLEMENTED_ENTITIES: ClassVar[RelationField] = RelationField(
-        "modelImplementedEntities"
-    )
-    """
-    TBC
-    """
-    OUTPUT_FROM_PROCESSES: ClassVar[RelationField] = RelationField(
-        "outputFromProcesses"
-    )
-    """
-    TBC
-    """
-
     _convenience_properties: ClassVar[List[str]] = [
         "adls_account_qualified_name",
         "adls_account_name",
         "azure_resource_id",
         "azure_location",
         "adls_account_secondary_location",
         "azure_tags",
-        "input_to_spark_jobs",
-        "input_to_airflow_tasks",
-        "input_to_processes",
-        "model_implemented_attributes",
-        "output_from_airflow_tasks",
-        "output_from_spark_jobs",
-        "model_implemented_entities",
-        "output_from_processes",
     ]
 
     @property
@@ -205,113 +148,7 @@ def azure_tags(self, azure_tags: Optional[List[AzureTag]]):
             self.attributes = self.Attributes()
         self.attributes.azure_tags = azure_tags
 
-    @property
-    def input_to_spark_jobs(self) -> Optional[List[SparkJob]]:
-        return None if self.attributes is None else self.attributes.input_to_spark_jobs
-
-    @input_to_spark_jobs.setter
-    def input_to_spark_jobs(self, input_to_spark_jobs: Optional[List[SparkJob]]):
-        if self.attributes is None:
-            self.attributes = self.Attributes()
-        self.attributes.input_to_spark_jobs = input_to_spark_jobs
-
-    @property
-    def input_to_airflow_tasks(self) -> Optional[List[AirflowTask]]:
-        return (
-            None if self.attributes is None else self.attributes.input_to_airflow_tasks
-        )
-
-    @input_to_airflow_tasks.setter
-    def input_to_airflow_tasks(
-        self, input_to_airflow_tasks: Optional[List[AirflowTask]]
-    ):
-        if self.attributes is None:
-            self.attributes = self.Attributes()
-        self.attributes.input_to_airflow_tasks = input_to_airflow_tasks
-
-    @property
-    def input_to_processes(self) -> Optional[List[Process]]:
-        return None if self.attributes is None else self.attributes.input_to_processes
-
-    @input_to_processes.setter
-    def input_to_processes(self, input_to_processes: Optional[List[Process]]):
-        if self.attributes is None:
-            self.attributes = self.Attributes()
-        self.attributes.input_to_processes = input_to_processes
-
-    @property
-    def model_implemented_attributes(self) -> Optional[List[ModelAttribute]]:
-        return (
-            None
-            if self.attributes is None
-            else self.attributes.model_implemented_attributes
-        )
-
-    @model_implemented_attributes.setter
-    def model_implemented_attributes(
-        self, model_implemented_attributes: Optional[List[ModelAttribute]]
-    ):
-        if self.attributes is None:
-            self.attributes = self.Attributes()
-        self.attributes.model_implemented_attributes = model_implemented_attributes
-
-    @property
-    def output_from_airflow_tasks(self) -> Optional[List[AirflowTask]]:
-        return (
-            None
-            if self.attributes is None
-            else self.attributes.output_from_airflow_tasks
-        )
-
-    @output_from_airflow_tasks.setter
-    def output_from_airflow_tasks(
-        self, output_from_airflow_tasks: Optional[List[AirflowTask]]
-    ):
-        if self.attributes is None:
-            self.attributes = self.Attributes()
-        self.attributes.output_from_airflow_tasks = output_from_airflow_tasks
-
-    @property
-    def output_from_spark_jobs(self) -> Optional[List[SparkJob]]:
-        return (
-            None if self.attributes is None else self.attributes.output_from_spark_jobs
-        )
-
-    @output_from_spark_jobs.setter
-    def output_from_spark_jobs(self, output_from_spark_jobs: Optional[List[SparkJob]]):
-        if self.attributes is None:
-            self.attributes = self.Attributes()
-        self.attributes.output_from_spark_jobs = output_from_spark_jobs
-
-    @property
-    def model_implemented_entities(self) -> Optional[List[ModelEntity]]:
-        return (
-            None
-            if self.attributes is None
-            else self.attributes.model_implemented_entities
-        )
-
-    @model_implemented_entities.setter
-    def model_implemented_entities(
-        self, model_implemented_entities: Optional[List[ModelEntity]]
-    ):
-        if self.attributes is None:
-            self.attributes = self.Attributes()
-        self.attributes.model_implemented_entities = model_implemented_entities
-
-    @property
-    def output_from_processes(self) -> Optional[List[Process]]:
-        return (
-            None if self.attributes is None else self.attributes.output_from_processes
-        )
-
-    @output_from_processes.setter
-    def output_from_processes(self, output_from_processes: Optional[List[Process]]):
-        if self.attributes is None:
-            self.attributes = self.Attributes()
-        self.attributes.output_from_processes = output_from_processes
-
-    class Attributes(Azure.Attributes):
+    class Attributes(ObjectStore.Attributes):
         adls_account_qualified_name: Optional[str] = Field(default=None, description="")
         adls_account_name: Optional[str] = Field(default=None, description="")
         azure_resource_id: Optional[str] = Field(default=None, description="")
@@ -320,30 +157,6 @@ class Attributes(Azure.Attributes):
             default=None, description=""
         )
         azure_tags: Optional[List[AzureTag]] = Field(default=None, description="")
-        input_to_spark_jobs: Optional[List[SparkJob]] = Field(
-            default=None, description=""
-        )  # relationship
-        input_to_airflow_tasks: Optional[List[AirflowTask]] = Field(
-            default=None, description=""
-        )  # relationship
-        input_to_processes: Optional[List[Process]] = Field(
-            default=None, description=""
-        )  # relationship
-        model_implemented_attributes: Optional[List[ModelAttribute]] = Field(
-            default=None, description=""
-        )  # relationship
-        output_from_airflow_tasks: Optional[List[AirflowTask]] = Field(
-            default=None, description=""
-        )  # relationship
-        output_from_spark_jobs: Optional[List[SparkJob]] = Field(
-            default=None, description=""
-        )  # relationship
-        model_implemented_entities: Optional[List[ModelEntity]] = Field(
-            default=None, description=""
-        )  # relationship
-        output_from_processes: Optional[List[Process]] = Field(
-            default=None, description=""
-        )  # relationship
 
     attributes: ADLS.Attributes = Field(
         default_factory=lambda: ADLS.Attributes(),
@@ -355,10 +168,4 @@ class Attributes(Azure.Attributes):
     )
 
 
-from .core.airflow_task import AirflowTask  # noqa: E402, F401
-from .core.model_attribute import ModelAttribute  # noqa: E402, F401
-from .core.model_entity import ModelEntity  # noqa: E402, F401
-from .core.process import Process  # noqa: E402, F401
-from .core.spark_job import SparkJob  # noqa: E402, F401
-
 ADLS.Attributes.update_forward_refs()

pyatlan/model/assets/core/__init__.py

@@ -190,8 +190,8 @@
 SnowflakeStage.Attributes.update_forward_refs(**localns)
 SnowflakeStream.Attributes.update_forward_refs(**localns)
 DatabricksUnityCatalogTag.Attributes.update_forward_refs(**localns)
-Database.Attributes.update_forward_refs(**localns)
 CalculationView.Attributes.update_forward_refs(**localns)
+Database.Attributes.update_forward_refs(**localns)
 Procedure.Attributes.update_forward_refs(**localns)
 SnowflakeTag.Attributes.update_forward_refs(**localns)
 MatillionGroup.Attributes.update_forward_refs(**localns)