Skip to content

Commit da242b9

Browse files
authored
Merge pull request #768 from atlanhq/APP-9295
App 9295 - Used KeywordField for AtlanTask.GUID
2 parents 1e511c0 + ed546d1 commit da242b9

55 files changed

Lines changed: 2684 additions & 813 deletions

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.
Lines changed: 10 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,10 @@
1+
.. _databricksmetricview:
2+
3+
DatabricksMetricView
4+
====================
5+
6+
.. module:: pyatlan.model.assets
7+
:no-index:
8+
9+
.. autoclass:: DatabricksMetricView
10+
:members:

docs/asset/partialv01.rst

Lines changed: 10 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,10 @@
1+
.. _partialv01:
2+
3+
PartialV01
4+
==========
5+
6+
.. module:: pyatlan.model.assets
7+
:no-index:
8+
9+
.. autoclass:: PartialV01
10+
:members:

docs/asset/partialv01field.rst

Lines changed: 10 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,10 @@
1+
.. _partialv01field:
2+
3+
PartialV01Field
4+
===============
5+
6+
.. module:: pyatlan.model.assets
7+
:no-index:
8+
9+
.. autoclass:: PartialV01Field
10+
:members:

docs/asset/partialv01object.rst

Lines changed: 10 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,10 @@
1+
.. _partialv01object:
2+
3+
PartialV01Object
4+
================
5+
6+
.. module:: pyatlan.model.assets
7+
:no-index:
8+
9+
.. autoclass:: PartialV01Object
10+
:members:

docs/assets.rst

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -130,6 +130,7 @@ You can interact with all of the following different kinds of assets:
130130
asset/databricksaimodelversion
131131
asset/databricksexternallocation
132132
asset/databricksexternallocationpath
133+
asset/databricksmetricview
133134
asset/databricksnotebook
134135
asset/databricksunitycatalogtag
135136
asset/databricksvolume
@@ -264,6 +265,9 @@ You can interact with all of the following different kinds of assets:
264265
asset/nosql
265266
asset/notebook
266267
asset/objectstore
268+
asset/partialv01
269+
asset/partialv01field
270+
asset/partialv01object
267271
asset/persona
268272
asset/powerbi
269273
asset/powerbiapp

pyatlan/model/assets/__init__.py

Lines changed: 6 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -30,6 +30,7 @@
3030
"Fivetran",
3131
"DataContract",
3232
"DataQuality",
33+
"PartialV01",
3334
"AI",
3435
"Resource",
3536
"FlowField",
@@ -71,6 +72,7 @@
7172
"Metric",
7273
"DataQualityRule",
7374
"Soda",
75+
"PartialV01Field",
7476
"AIApplication",
7577
"AIModelVersion",
7678
"AIModel",
@@ -79,7 +81,6 @@
7981
"Link",
8082
"DataDomain",
8183
"DataProduct",
82-
"Dremio",
8384
"Table",
8485
"Query",
8586
"Schema",
@@ -90,8 +91,8 @@
9091
"TablePartition",
9192
"Column",
9293
"SnowflakeStage",
93-
"DatabricksUnityCatalogTag",
9494
"SnowflakeStream",
95+
"DatabricksUnityCatalogTag",
9596
"Database",
9697
"CalculationView",
9798
"Procedure",
@@ -151,6 +152,7 @@
151152
"SnowflakeAIModelContext",
152153
"DatabricksAIModelContext",
153154
"SnowflakeDynamicTable",
155+
"DatabricksMetricView",
154156
"BigqueryRoutine",
155157
"DatabricksVolume",
156158
"DatabricksVolumePath",
@@ -229,6 +231,7 @@
229231
"a_d_l_s": ["ADLS"],
230232
"g_c_s": ["GCS"],
231233
"databricks_notebook": ["DatabricksNotebook"],
234+
"partial_v01_object": ["PartialV01Object"],
232235
"dataverse": ["Dataverse"],
233236
"cognite": ["Cognite"],
234237
"salesforce": ["Salesforce"],
@@ -238,6 +241,7 @@
238241
"cube_dimension": ["CubeDimension"],
239242
"cube_field": ["CubeField"],
240243
"custom_entity": ["CustomEntity"],
244+
"dremio": ["Dremio"],
241245
"bigquery_tag": ["BigqueryTag"],
242246
"snowflake": ["Snowflake"],
243247
"a_p_i_spec": ["APISpec"],

pyatlan/model/assets/__init__.pyi

Lines changed: 11 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -27,6 +27,7 @@ __all__ = [
2727
"Fivetran",
2828
"DataContract",
2929
"DataQuality",
30+
"PartialV01",
3031
"AI",
3132
"Resource",
3233
"FlowField",
@@ -68,6 +69,7 @@ __all__ = [
6869
"Metric",
6970
"DataQualityRule",
7071
"Soda",
72+
"PartialV01Field",
7173
"AIApplication",
7274
"AIModelVersion",
7375
"AIModel",
@@ -76,7 +78,6 @@ __all__ = [
7678
"Link",
7779
"DataDomain",
7880
"DataProduct",
79-
"Dremio",
8081
"Table",
8182
"Query",
8283
"Schema",
@@ -87,8 +88,8 @@ __all__ = [
8788
"TablePartition",
8889
"Column",
8990
"SnowflakeStage",
90-
"DatabricksUnityCatalogTag",
9191
"SnowflakeStream",
92+
"DatabricksUnityCatalogTag",
9293
"Database",
9394
"CalculationView",
9495
"Procedure",
@@ -148,6 +149,7 @@ __all__ = [
148149
"SnowflakeAIModelContext",
149150
"DatabricksAIModelContext",
150151
"SnowflakeDynamicTable",
152+
"DatabricksMetricView",
151153
"BigqueryRoutine",
152154
"DatabricksVolume",
153155
"DatabricksVolumePath",
@@ -225,6 +227,7 @@ __all__ = [
225227
"ADLS",
226228
"GCS",
227229
"DatabricksNotebook",
230+
"PartialV01Object",
228231
"Dataverse",
229232
"Cognite",
230233
"Salesforce",
@@ -234,6 +237,7 @@ __all__ = [
234237
"CubeDimension",
235238
"CubeField",
236239
"CustomEntity",
240+
"Dremio",
237241
"BigqueryTag",
238242
"Snowflake",
239243
"APISpec",
@@ -507,6 +511,7 @@ from .core.database import Database
507511
from .core.databricks import Databricks
508512
from .core.databricks_a_i_model_context import DatabricksAIModelContext
509513
from .core.databricks_a_i_model_version import DatabricksAIModelVersion
514+
from .core.databricks_metric_view import DatabricksMetricView
510515
from .core.databricks_unity_catalog_tag import DatabricksUnityCatalogTag
511516
from .core.databricks_volume import DatabricksVolume
512517
from .core.databricks_volume_path import DatabricksVolumePath
@@ -520,7 +525,6 @@ from .core.dbt_test import DbtTest
520525
from .core.document_d_b import DocumentDB
521526
from .core.document_d_b_collection import DocumentDBCollection
522527
from .core.document_d_b_database import DocumentDBDatabase
523-
from .core.dremio import Dremio
524528
from .core.dynamo_d_b_secondary_index import DynamoDBSecondaryIndex
525529
from .core.fabric import Fabric
526530
from .core.fabric_activity import FabricActivity
@@ -570,6 +574,8 @@ from .core.mongo_d_b_database import MongoDBDatabase
570574
from .core.monte_carlo import MonteCarlo
571575
from .core.namespace import Namespace
572576
from .core.no_s_q_l import NoSQL
577+
from .core.partial_v01 import PartialV01
578+
from .core.partial_v01_field import PartialV01Field
573579
from .core.persona import Persona
574580
from .core.power_b_i import PowerBI
575581
from .core.power_b_i_app import PowerBIApp
@@ -635,6 +641,7 @@ from .domo_card import DomoCard
635641
from .domo_dashboard import DomoDashboard
636642
from .domo_dataset import DomoDataset
637643
from .domo_dataset_column import DomoDatasetColumn
644+
from .dremio import Dremio
638645
from .dremio_column import DremioColumn
639646
from .dremio_folder import DremioFolder
640647
from .dremio_physical_dataset import DremioPhysicalDataset
@@ -695,6 +702,7 @@ from .mongo_d_b import MongoDB
695702
from .multi_dimensional_dataset import MultiDimensionalDataset
696703
from .notebook import Notebook
697704
from .object_store import ObjectStore
705+
from .partial_v01_object import PartialV01Object
698706
from .preset import Preset
699707
from .preset_chart import PresetChart
700708
from .preset_dashboard import PresetDashboard

pyatlan/model/assets/a_d_l_s.py

Lines changed: 27 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -8,7 +8,11 @@
88

99
from pydantic.v1 import Field, validator
1010

11-
from pyatlan.model.fields.atlan_fields import KeywordField, KeywordTextField
11+
from pyatlan.model.fields.atlan_fields import (
12+
BooleanField,
13+
KeywordField,
14+
KeywordTextField,
15+
)
1216
from pyatlan.model.structs import AzureTag
1317

1418
from .object_store import ObjectStore
@@ -44,6 +48,12 @@ def __setattr__(self, name, value):
4448
"""
4549
Name of the account for this ADLS asset.
4650
"""
51+
CATALOG_HAS_PARTIAL_FIELDS: ClassVar[BooleanField] = BooleanField(
52+
"catalogHasPartialFields", "catalogHasPartialFields"
53+
)
54+
"""
55+
Indicates this catalog asset has partial fields, if true.
56+
"""
4757
AZURE_RESOURCE_ID: ClassVar[KeywordTextField] = KeywordTextField(
4858
"azureResourceId", "azureResourceId", "azureResourceId.text"
4959
)
@@ -70,6 +80,7 @@ def __setattr__(self, name, value):
7080
_convenience_properties: ClassVar[List[str]] = [
7181
"adls_account_qualified_name",
7282
"adls_account_name",
83+
"catalog_has_partial_fields",
7384
"azure_resource_id",
7485
"azure_location",
7586
"adls_account_secondary_location",
@@ -100,6 +111,20 @@ def adls_account_name(self, adls_account_name: Optional[str]):
100111
self.attributes = self.Attributes()
101112
self.attributes.adls_account_name = adls_account_name
102113

114+
@property
115+
def catalog_has_partial_fields(self) -> Optional[bool]:
116+
return (
117+
None
118+
if self.attributes is None
119+
else self.attributes.catalog_has_partial_fields
120+
)
121+
122+
@catalog_has_partial_fields.setter
123+
def catalog_has_partial_fields(self, catalog_has_partial_fields: Optional[bool]):
124+
if self.attributes is None:
125+
self.attributes = self.Attributes()
126+
self.attributes.catalog_has_partial_fields = catalog_has_partial_fields
127+
103128
@property
104129
def azure_resource_id(self) -> Optional[str]:
105130
return None if self.attributes is None else self.attributes.azure_resource_id
@@ -151,6 +176,7 @@ def azure_tags(self, azure_tags: Optional[List[AzureTag]]):
151176
class Attributes(ObjectStore.Attributes):
152177
adls_account_qualified_name: Optional[str] = Field(default=None, description="")
153178
adls_account_name: Optional[str] = Field(default=None, description="")
179+
catalog_has_partial_fields: Optional[bool] = Field(default=None, description="")
154180
azure_resource_id: Optional[str] = Field(default=None, description="")
155181
azure_location: Optional[str] = Field(default=None, description="")
156182
adls_account_secondary_location: Optional[str] = Field(

pyatlan/model/assets/bigquery_tag.py

Lines changed: 22 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -77,6 +77,12 @@ def __setattr__(self, name, value):
7777
"""
7878
Name of the classification in Atlan that is mapped to this tag.
7979
"""
80+
CATALOG_HAS_PARTIAL_FIELDS: ClassVar[BooleanField] = BooleanField(
81+
"catalogHasPartialFields", "catalogHasPartialFields"
82+
)
83+
"""
84+
Indicates this catalog asset has partial fields, if true.
85+
"""
8086
QUERY_COUNT: ClassVar[NumericField] = NumericField("queryCount", "queryCount")
8187
"""
8288
Number of times this asset has been queried.
@@ -213,6 +219,7 @@ def __setattr__(self, name, value):
213219
"tag_attributes",
214220
"tag_allowed_values",
215221
"mapped_atlan_tag_name",
222+
"catalog_has_partial_fields",
216223
"query_count",
217224
"query_user_count",
218225
"query_user_map",
@@ -323,6 +330,20 @@ def mapped_atlan_tag_name(self, mapped_atlan_tag_name: Optional[str]):
323330
self.attributes = self.Attributes()
324331
self.attributes.mapped_atlan_tag_name = mapped_atlan_tag_name
325332

333+
@property
334+
def catalog_has_partial_fields(self) -> Optional[bool]:
335+
return (
336+
None
337+
if self.attributes is None
338+
else self.attributes.catalog_has_partial_fields
339+
)
340+
341+
@catalog_has_partial_fields.setter
342+
def catalog_has_partial_fields(self, catalog_has_partial_fields: Optional[bool]):
343+
if self.attributes is None:
344+
self.attributes = self.Attributes()
345+
self.attributes.catalog_has_partial_fields = catalog_has_partial_fields
346+
326347
@property
327348
def query_count(self) -> Optional[int]:
328349
return None if self.attributes is None else self.attributes.query_count
@@ -601,6 +622,7 @@ class Attributes(Tag.Attributes):
601622
)
602623
tag_allowed_values: Optional[Set[str]] = Field(default=None, description="")
603624
mapped_atlan_tag_name: Optional[str] = Field(default=None, description="")
625+
catalog_has_partial_fields: Optional[bool] = Field(default=None, description="")
604626
query_count: Optional[int] = Field(default=None, description="")
605627
query_user_count: Optional[int] = Field(default=None, description="")
606628
query_user_map: Optional[Dict[str, int]] = Field(default=None, description="")

pyatlan/model/assets/core/__init__.py

Lines changed: 7 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -48,6 +48,7 @@
4848
from .databricks import Databricks
4949
from .databricks_a_i_model_context import DatabricksAIModelContext
5050
from .databricks_a_i_model_version import DatabricksAIModelVersion
51+
from .databricks_metric_view import DatabricksMetricView
5152
from .databricks_unity_catalog_tag import DatabricksUnityCatalogTag
5253
from .databricks_volume import DatabricksVolume
5354
from .databricks_volume_path import DatabricksVolumePath
@@ -61,7 +62,6 @@
6162
from .document_d_b import DocumentDB
6263
from .document_d_b_collection import DocumentDBCollection
6364
from .document_d_b_database import DocumentDBDatabase
64-
from .dremio import Dremio
6565
from .dynamo_d_b_secondary_index import DynamoDBSecondaryIndex
6666
from .fabric import Fabric
6767
from .fabric_activity import FabricActivity
@@ -111,6 +111,8 @@
111111
from .monte_carlo import MonteCarlo
112112
from .namespace import Namespace
113113
from .no_s_q_l import NoSQL
114+
from .partial_v01 import PartialV01
115+
from .partial_v01_field import PartialV01Field
114116
from .persona import Persona
115117
from .power_b_i import PowerBI
116118
from .power_b_i_app import PowerBIApp
@@ -181,6 +183,7 @@
181183
Fivetran.Attributes.update_forward_refs(**localns)
182184
DataContract.Attributes.update_forward_refs(**localns)
183185
DataQuality.Attributes.update_forward_refs(**localns)
186+
PartialV01.Attributes.update_forward_refs(**localns)
184187
AI.Attributes.update_forward_refs(**localns)
185188
Resource.Attributes.update_forward_refs(**localns)
186189
FlowField.Attributes.update_forward_refs(**localns)
@@ -222,6 +225,7 @@
222225
Metric.Attributes.update_forward_refs(**localns)
223226
DataQualityRule.Attributes.update_forward_refs(**localns)
224227
Soda.Attributes.update_forward_refs(**localns)
228+
PartialV01Field.Attributes.update_forward_refs(**localns)
225229
AIApplication.Attributes.update_forward_refs(**localns)
226230
AIModelVersion.Attributes.update_forward_refs(**localns)
227231
AIModel.Attributes.update_forward_refs(**localns)
@@ -230,7 +234,6 @@
230234
Link.Attributes.update_forward_refs(**localns)
231235
DataDomain.Attributes.update_forward_refs(**localns)
232236
DataProduct.Attributes.update_forward_refs(**localns)
233-
Dremio.Attributes.update_forward_refs(**localns)
234237
Table.Attributes.update_forward_refs(**localns)
235238
Query.Attributes.update_forward_refs(**localns)
236239
Schema.Attributes.update_forward_refs(**localns)
@@ -241,8 +244,8 @@
241244
TablePartition.Attributes.update_forward_refs(**localns)
242245
Column.Attributes.update_forward_refs(**localns)
243246
SnowflakeStage.Attributes.update_forward_refs(**localns)
244-
DatabricksUnityCatalogTag.Attributes.update_forward_refs(**localns)
245247
SnowflakeStream.Attributes.update_forward_refs(**localns)
248+
DatabricksUnityCatalogTag.Attributes.update_forward_refs(**localns)
246249
Database.Attributes.update_forward_refs(**localns)
247250
CalculationView.Attributes.update_forward_refs(**localns)
248251
Procedure.Attributes.update_forward_refs(**localns)
@@ -302,6 +305,7 @@
302305
SnowflakeAIModelContext.Attributes.update_forward_refs(**localns)
303306
DatabricksAIModelContext.Attributes.update_forward_refs(**localns)
304307
SnowflakeDynamicTable.Attributes.update_forward_refs(**localns)
308+
DatabricksMetricView.Attributes.update_forward_refs(**localns)
305309
BigqueryRoutine.Attributes.update_forward_refs(**localns)
306310
DatabricksVolume.Attributes.update_forward_refs(**localns)
307311
DatabricksVolumePath.Attributes.update_forward_refs(**localns)

0 commit comments

Comments
 (0)