Skip to content

Commit 1b8f7c8

Browse files
authored
Merge branch 'main' into FT-897
2 parents e83a5c3 + f69f841 commit 1b8f7c8

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

51 files changed

+3309
-25
lines changed

docs/asset/customentity.rst

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

docs/assets.rst

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -95,6 +95,8 @@ You can interact with all of the following different kinds of assets:
9595
asset/cubedimension
9696
asset/cubefield
9797
asset/cubehierarchy
98+
asset/custom
99+
asset/customentity
98100
asset/datacontract
99101
asset/datadomain
100102
asset/datamesh
@@ -204,6 +206,7 @@ You can interact with all of the following different kinds of assets:
204206
asset/powerbicolumn
205207
asset/powerbidashboard
206208
asset/powerbidataflow
209+
asset/powerbidataflowentitycolumn
207210
asset/powerbidataset
208211
asset/powerbidatasource
209212
asset/powerbimeasure
Lines changed: 11 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,11 @@
1+
2+
@classmethod
3+
@init_guid
4+
def creator(cls, *, name: str, connection_qualified_name: str) -> CustomEntity:
5+
validate_required_fields(
6+
["name", "connection_qualified_name"], [name, connection_qualified_name]
7+
)
8+
attributes = CustomEntity.Attributes.creator(
9+
name=name, connection_qualified_name=connection_qualified_name
10+
)
11+
return cls(attributes=attributes)
Lines changed: 38 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,38 @@
1+
2+
@overload
3+
@classmethod
4+
def creator(
5+
cls,
6+
*,
7+
name: str,
8+
dataverse_entity_qualified_name: str,
9+
) -> DataverseAttribute: ...
10+
11+
@overload
12+
@classmethod
13+
def creator(
14+
cls,
15+
*,
16+
name: str,
17+
dataverse_entity_qualified_name: str,
18+
connection_qualified_name: str,
19+
) -> DataverseAttribute: ...
20+
21+
@classmethod
22+
@init_guid
23+
def creator(
24+
cls,
25+
*,
26+
name: str,
27+
dataverse_entity_qualified_name: str,
28+
connection_qualified_name: Optional[str] = None,
29+
) -> DataverseAttribute:
30+
validate_required_fields(
31+
["name", "dataverse_entity_qualified_name"], [name, dataverse_entity_qualified_name],
32+
)
33+
attributes = DataverseAttribute.Attributes.creator(
34+
name=name,
35+
dataverse_entity_qualified_name=dataverse_entity_qualified_name,
36+
connection_qualified_name=connection_qualified_name,
37+
)
38+
return cls(attributes=attributes)
Lines changed: 12 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,12 @@
1+
2+
@classmethod
3+
@init_guid
4+
def creator(cls, *, name: str, connection_qualified_name: str) -> DataverseEntity:
5+
validate_required_fields(
6+
["name", "connection_qualified_name"], [name, connection_qualified_name],
7+
)
8+
attributes = DataverseEntity.Attributes.creator(
9+
name=name,
10+
connection_qualified_name=connection_qualified_name,
11+
)
12+
return cls(attributes=attributes)
Lines changed: 17 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,17 @@
1+
2+
@classmethod
3+
@init_guid
4+
def creator(
5+
cls, *, name: str, connection_qualified_name: str
6+
) -> CustomEntity.Attributes:
7+
validate_required_fields(
8+
["name", "connection_qualified_name"], [name, connection_qualified_name]
9+
)
10+
return CustomEntity.Attributes(
11+
name=name,
12+
qualified_name=f"{connection_qualified_name}/{name}",
13+
connection_qualified_name=connection_qualified_name,
14+
connector_name=AtlanConnectorType.get_connector_name(
15+
connection_qualified_name
16+
),
17+
)
Lines changed: 35 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,35 @@
1+
2+
@classmethod
3+
@init_guid
4+
def creator(
5+
cls,
6+
*,
7+
name: str,
8+
dataverse_entity_qualified_name: str,
9+
connection_qualified_name: Optional[str] = None,
10+
) -> DataverseAttribute.Attributes:
11+
validate_required_fields(
12+
["name", "dataverse_entity_qualified_name"],
13+
[name, dataverse_entity_qualified_name],
14+
)
15+
if connection_qualified_name:
16+
connector_name = AtlanConnectorType.get_connector_name(
17+
connection_qualified_name
18+
)
19+
else:
20+
connection_qn, connector_name = AtlanConnectorType.get_connector_name(
21+
dataverse_entity_qualified_name,
22+
"dataverse_entity_qualified_name",
23+
4,
24+
)
25+
26+
return DataverseAttribute.Attributes(
27+
name=name,
28+
dataverse_entity_qualified_name=dataverse_entity_qualified_name,
29+
connection_qualified_name=connection_qualified_name or connection_qn,
30+
qualified_name=f"{dataverse_entity_qualified_name}/{name}",
31+
connector_name=connector_name,
32+
dataverse_entity=DataverseEntity.ref_by_qualified_name(
33+
dataverse_entity_qualified_name
34+
),
35+
)
Lines changed: 17 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,17 @@
1+
2+
@classmethod
3+
@init_guid
4+
def creator(
5+
cls, *, name: str, connection_qualified_name: str
6+
) -> DataverseEntity.Attributes:
7+
validate_required_fields(
8+
["name", "connection_qualified_name"], [name, connection_qualified_name],
9+
)
10+
return DataverseEntity.Attributes(
11+
name=name,
12+
qualified_name=f"{connection_qualified_name}/{name}",
13+
connection_qualified_name=connection_qualified_name,
14+
connector_name=AtlanConnectorType.get_connector_name(
15+
connection_qualified_name
16+
),
17+
)

pyatlan/model/assets/__init__.py

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -104,6 +104,7 @@
104104
"PowerBIDashboard",
105105
"PowerBIDataflow",
106106
"PowerBIPage",
107+
"PowerBIDataflowEntityColumn",
107108
"SnowflakeDynamicTable",
108109
"MongoDBCollection",
109110
"DynamoDBSecondaryIndex",
@@ -133,6 +134,7 @@
133134
"object_store": ["ObjectStore"],
134135
"saa_s": ["SaaS"],
135136
"multi_dimensional_dataset": ["MultiDimensionalDataset"],
137+
"custom": ["Custom"],
136138
"event_store": ["EventStore"],
137139
"insight": ["Insight"],
138140
"a_p_i": ["API"],
@@ -169,6 +171,7 @@
169171
"cube_hierarchy": ["CubeHierarchy"],
170172
"cube_field": ["CubeField"],
171173
"cube_dimension": ["CubeDimension"],
174+
"custom_entity": ["CustomEntity"],
172175
"bigquery_tag": ["BigqueryTag"],
173176
"kafka": ["Kafka"],
174177
"azure_service_bus": ["AzureServiceBus"],

0 commit comments

Comments
 (0)