[generator] Regenerated latest typedef models

Author: Aryamanz29

pyatlan/model/assets/__init__.py

@@ -76,8 +76,8 @@
         "SnowflakeStage",
         "SnowflakeStream",
         "DatabricksUnityCatalogTag",
-        "CalculationView",
         "Database",
+        "CalculationView",
         "Procedure",
         "SnowflakeTag",
         "MatillionGroup",

pyatlan/model/assets/__init__.pyi

@@ -73,8 +73,8 @@ __all__ = [
     "SnowflakeStage",
     "SnowflakeStream",
     "DatabricksUnityCatalogTag",
-    "CalculationView",
     "Database",
+    "CalculationView",
     "Procedure",
     "SnowflakeTag",
     "MatillionGroup",

pyatlan/model/assets/auth_service.py

@@ -39,6 +39,10 @@ def __setattr__(self, name, value):
     """
     TBC
     """
+    ABAC_SERVICE: ClassVar[KeywordField] = KeywordField("abacService", "abacService")
+    """
+    TBC
+    """
     AUTH_SERVICE_IS_ENABLED: ClassVar[BooleanField] = BooleanField(
         "authServiceIsEnabled", "authServiceIsEnabled"
     )
@@ -61,6 +65,7 @@ def __setattr__(self, name, value):
     _convenience_properties: ClassVar[List[str]] = [
         "auth_service_type",
         "tag_service",
+        "abac_service",
         "auth_service_is_enabled",
         "auth_service_config",
         "auth_service_policy_last_sync",
@@ -86,6 +91,16 @@ def tag_service(self, tag_service: Optional[str]):
             self.attributes = self.Attributes()
         self.attributes.tag_service = tag_service
 
+    @property
+    def abac_service(self) -> Optional[str]:
+        return None if self.attributes is None else self.attributes.abac_service
+
+    @abac_service.setter
+    def abac_service(self, abac_service: Optional[str]):
+        if self.attributes is None:
+            self.attributes = self.Attributes()
+        self.attributes.abac_service = abac_service
+
     @property
     def auth_service_is_enabled(self) -> Optional[bool]:
         return (
@@ -127,6 +142,7 @@ def auth_service_policy_last_sync(
     class Attributes(Asset.Attributes):
         auth_service_type: Optional[str] = Field(default=None, description="")
         tag_service: Optional[str] = Field(default=None, description="")
+        abac_service: Optional[str] = Field(default=None, description="")
         auth_service_is_enabled: Optional[bool] = Field(default=None, description="")
         auth_service_config: Optional[Dict[str, str]] = Field(
             default=None, description=""

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)
-CalculationView.Attributes.update_forward_refs(**localns)
 Database.Attributes.update_forward_refs(**localns)
+CalculationView.Attributes.update_forward_refs(**localns)
 Procedure.Attributes.update_forward_refs(**localns)
 SnowflakeTag.Attributes.update_forward_refs(**localns)
 MatillionGroup.Attributes.update_forward_refs(**localns)

pyatlan/model/assets/core/auth_policy.py

@@ -15,6 +15,7 @@
     KeywordField,
     NumericField,
     RelationField,
+    TextField,
 )
 from pyatlan.model.structs import AuthPolicyCondition, AuthPolicyValiditySchedule
 from pyatlan.utils import init_guid, validate_required_fields
@@ -80,6 +81,12 @@ def __setattr__(self, name, value):
             return object.__setattr__(self, name, value)
         super().__setattr__(name, value)
 
+    POLICY_FILTER_CRITERIA: ClassVar[TextField] = TextField(
+        "policyFilterCriteria", "policyFilterCriteria"
+    )
+    """
+    TBC
+    """
     POLICY_TYPE: ClassVar[KeywordField] = KeywordField("policyType", "policyType")
     """
     TBC
@@ -181,6 +188,7 @@ def __setattr__(self, name, value):
     """
 
     _convenience_properties: ClassVar[List[str]] = [
+        "policy_filter_criteria",
         "policy_type",
         "policy_service_name",
         "policy_category",
@@ -201,6 +209,18 @@ def __setattr__(self, name, value):
         "access_control",
     ]
 
+    @property
+    def policy_filter_criteria(self) -> Optional[str]:
+        return (
+            None if self.attributes is None else self.attributes.policy_filter_criteria
+        )
+
+    @policy_filter_criteria.setter
+    def policy_filter_criteria(self, policy_filter_criteria: Optional[str]):
+        if self.attributes is None:
+            self.attributes = self.Attributes()
+        self.attributes.policy_filter_criteria = policy_filter_criteria
+
     @property
     def policy_type(self) -> Optional[AuthPolicyType]:
         return None if self.attributes is None else self.attributes.policy_type
@@ -398,6 +418,7 @@ def access_control(self, access_control: Optional[AccessControl]):
         self.attributes.access_control = access_control
 
     class Attributes(Asset.Attributes):
+        policy_filter_criteria: Optional[str] = Field(default=None, description="")
         policy_type: Optional[AuthPolicyType] = Field(default=None, description="")
         policy_service_name: Optional[str] = Field(default=None, description="")
         policy_category: Optional[str] = Field(default=None, description="")

pyatlan/model/assets/core/column.py

@@ -201,6 +201,18 @@ def __setattr__(self, name, value):
     """
     Sub-data type of this column.
     """
+    COLUMN_COMPRESSION: ClassVar[KeywordField] = KeywordField(
+        "columnCompression", "columnCompression"
+    )
+    """
+    Compression type of this column.
+    """
+    COLUMN_ENCODING: ClassVar[KeywordField] = KeywordField(
+        "columnEncoding", "columnEncoding"
+    )
+    """
+    Encoding type of this column.
+    """
     RAW_DATA_TYPE_DEFINITION: ClassVar[TextField] = TextField(
         "rawDataTypeDefinition", "rawDataTypeDefinition"
     )
@@ -548,6 +560,8 @@ def __setattr__(self, name, value):
     _convenience_properties: ClassVar[List[str]] = [
         "data_type",
         "sub_data_type",
+        "column_compression",
+        "column_encoding",
         "raw_data_type_definition",
         "order",
         "nested_column_order",
@@ -639,6 +653,26 @@ def sub_data_type(self, sub_data_type: Optional[str]):
             self.attributes = self.Attributes()
         self.attributes.sub_data_type = sub_data_type
 
+    @property
+    def column_compression(self) -> Optional[str]:
+        return None if self.attributes is None else self.attributes.column_compression
+
+    @column_compression.setter
+    def column_compression(self, column_compression: Optional[str]):
+        if self.attributes is None:
+            self.attributes = self.Attributes()
+        self.attributes.column_compression = column_compression
+
+    @property
+    def column_encoding(self) -> Optional[str]:
+        return None if self.attributes is None else self.attributes.column_encoding
+
+    @column_encoding.setter
+    def column_encoding(self, column_encoding: Optional[str]):
+        if self.attributes is None:
+            self.attributes = self.Attributes()
+        self.attributes.column_encoding = column_encoding
+
     @property
     def raw_data_type_definition(self) -> Optional[str]:
         return (
@@ -1452,6 +1486,8 @@ def table_partition(self, table_partition: Optional[TablePartition]):
     class Attributes(SQL.Attributes):
         data_type: Optional[str] = Field(default=None, description="")
         sub_data_type: Optional[str] = Field(default=None, description="")
+        column_compression: Optional[str] = Field(default=None, description="")
+        column_encoding: Optional[str] = Field(default=None, description="")
         raw_data_type_definition: Optional[str] = Field(default=None, description="")
         order: Optional[int] = Field(default=None, description="")
         nested_column_order: Optional[str] = Field(default=None, description="")

pyatlan/model/assets/core/cosmos_mongo_d_b_collection.py

@@ -140,6 +140,12 @@ def __setattr__(self, name, value):
     """
     Size of this table, in bytes.
     """
+    TABLE_OBJECT_COUNT: ClassVar[NumericField] = NumericField(
+        "tableObjectCount", "tableObjectCount"
+    )
+    """
+    Number of objects in this table.
+    """
     ALIAS: ClassVar[TextField] = TextField("alias", "alias")
     """
     Alias for this table.
@@ -196,6 +202,12 @@ def __setattr__(self, name, value):
     """
     Number of partitions in this table.
     """
+    TABLE_DEFINITION: ClassVar[TextField] = TextField(
+        "tableDefinition", "tableDefinition"
+    )
+    """
+    Definition of the table.
+    """
     PARTITION_LIST: ClassVar[TextField] = TextField("partitionList", "partitionList")
     """
     List of partitions in this table.
@@ -212,43 +224,49 @@ def __setattr__(self, name, value):
         "icebergCatalogName", "icebergCatalogName"
     )
     """
-    iceberg table catalog name (can be any user defined name)
+    Iceberg table catalog name (can be any user defined name)
     """
     ICEBERG_TABLE_TYPE: ClassVar[KeywordField] = KeywordField(
         "icebergTableType", "icebergTableType"
     )
     """
-    iceberg table type (managed vs unmanaged)
+    Iceberg table type (managed vs unmanaged)
     """
     ICEBERG_CATALOG_SOURCE: ClassVar[KeywordField] = KeywordField(
         "icebergCatalogSource", "icebergCatalogSource"
     )
     """
-    iceberg table catalog type (glue, polaris, snowflake)
+    Iceberg table catalog type (glue, polaris, snowflake)
     """
     ICEBERG_CATALOG_TABLE_NAME: ClassVar[KeywordField] = KeywordField(
         "icebergCatalogTableName", "icebergCatalogTableName"
     )
     """
-    catalog table name (actual table name on the catalog side).
+    Catalog table name (actual table name on the catalog side).
+    """
+    TABLE_IMPALA_PARAMETERS: ClassVar[KeywordField] = KeywordField(
+        "tableImpalaParameters", "tableImpalaParameters"
+    )
+    """
+    Extra attributes for Impala
     """
     ICEBERG_CATALOG_TABLE_NAMESPACE: ClassVar[KeywordField] = KeywordField(
         "icebergCatalogTableNamespace", "icebergCatalogTableNamespace"
     )
     """
-    catalog table namespace (actual database name on the catalog side).
+    Catalog table namespace (actual database name on the catalog side).
     """
     TABLE_EXTERNAL_VOLUME_NAME: ClassVar[KeywordField] = KeywordField(
         "tableExternalVolumeName", "tableExternalVolumeName"
     )
     """
-    external volume name for the table.
+    External volume name for the table.
     """
     ICEBERG_TABLE_BASE_LOCATION: ClassVar[KeywordField] = KeywordField(
         "icebergTableBaseLocation", "icebergTableBaseLocation"
     )
     """
-    iceberg table base location inside the external volume.
+    Iceberg table base location inside the external volume.
     """
     TABLE_RETENTION_TIME: ClassVar[NumericField] = NumericField(
         "tableRetentionTime", "tableRetentionTime"
@@ -422,6 +440,7 @@ def __setattr__(self, name, value):
         "column_count",
         "row_count",
         "size_bytes",
+        "table_object_count",
         "alias",
         "is_temporary",
         "is_query_preview",
@@ -432,13 +451,15 @@ def __setattr__(self, name, value):
         "is_partitioned",
         "partition_strategy",
         "partition_count",
+        "table_definition",
         "partition_list",
         "is_sharded",
         "table_type",
         "iceberg_catalog_name",
         "iceberg_table_type",
         "iceberg_catalog_source",
         "iceberg_catalog_table_name",
+        "table_impala_parameters",
         "iceberg_catalog_table_namespace",
         "table_external_volume_name",
         "iceberg_table_base_location",
@@ -744,6 +765,16 @@ def size_bytes(self, size_bytes: Optional[int]):
             self.attributes = self.Attributes()
         self.attributes.size_bytes = size_bytes
 
+    @property
+    def table_object_count(self) -> Optional[int]:
+        return None if self.attributes is None else self.attributes.table_object_count
+
+    @table_object_count.setter
+    def table_object_count(self, table_object_count: Optional[int]):
+        if self.attributes is None:
+            self.attributes = self.Attributes()
+        self.attributes.table_object_count = table_object_count
+
     @property
     def alias(self) -> Optional[str]:
         return None if self.attributes is None else self.attributes.alias
@@ -852,6 +883,16 @@ def partition_count(self, partition_count: Optional[int]):
             self.attributes = self.Attributes()
         self.attributes.partition_count = partition_count
 
+    @property
+    def table_definition(self) -> Optional[str]:
+        return None if self.attributes is None else self.attributes.table_definition
+
+    @table_definition.setter
+    def table_definition(self, table_definition: Optional[str]):
+        if self.attributes is None:
+            self.attributes = self.Attributes()
+        self.attributes.table_definition = table_definition
+
     @property
     def partition_list(self) -> Optional[str]:
         return None if self.attributes is None else self.attributes.partition_list
@@ -928,6 +969,20 @@ def iceberg_catalog_table_name(self, iceberg_catalog_table_name: Optional[str]):
             self.attributes = self.Attributes()
         self.attributes.iceberg_catalog_table_name = iceberg_catalog_table_name
 
+    @property
+    def table_impala_parameters(self) -> Optional[Dict[str, str]]:
+        return (
+            None if self.attributes is None else self.attributes.table_impala_parameters
+        )
+
+    @table_impala_parameters.setter
+    def table_impala_parameters(
+        self, table_impala_parameters: Optional[Dict[str, str]]
+    ):
+        if self.attributes is None:
+            self.attributes = self.Attributes()
+        self.attributes.table_impala_parameters = table_impala_parameters
+
     @property
     def iceberg_catalog_table_namespace(self) -> Optional[str]:
         return (
@@ -1340,6 +1395,7 @@ class Attributes(CosmosMongoDB.Attributes):
         column_count: Optional[int] = Field(default=None, description="")
         row_count: Optional[int] = Field(default=None, description="")
         size_bytes: Optional[int] = Field(default=None, description="")
+        table_object_count: Optional[int] = Field(default=None, description="")
         alias: Optional[str] = Field(default=None, description="")
         is_temporary: Optional[bool] = Field(default=None, description="")
         is_query_preview: Optional[bool] = Field(default=None, description="")
@@ -1352,13 +1408,17 @@ class Attributes(CosmosMongoDB.Attributes):
         is_partitioned: Optional[bool] = Field(default=None, description="")
         partition_strategy: Optional[str] = Field(default=None, description="")
         partition_count: Optional[int] = Field(default=None, description="")
+        table_definition: Optional[str] = Field(default=None, description="")
         partition_list: Optional[str] = Field(default=None, description="")
         is_sharded: Optional[bool] = Field(default=None, description="")
         table_type: Optional[TableType] = Field(default=None, description="")
         iceberg_catalog_name: Optional[str] = Field(default=None, description="")
         iceberg_table_type: Optional[str] = Field(default=None, description="")
         iceberg_catalog_source: Optional[str] = Field(default=None, description="")
         iceberg_catalog_table_name: Optional[str] = Field(default=None, description="")
+        table_impala_parameters: Optional[Dict[str, str]] = Field(
+            default=None, description=""
+        )
         iceberg_catalog_table_namespace: Optional[str] = Field(
             default=None, description=""
         )