Skip to content

Commit a360f2a

Browse files
vaibhavatlanAryamanz29
authored andcommitted
fixing how tag mutation is handeled for terms and categories
1 parent 9059925 commit a360f2a

File tree

2 files changed

+40
-42
lines changed

2 files changed

+40
-42
lines changed

pyatlan/client/asset.py

Lines changed: 40 additions & 14 deletions
Original file line numberDiff line numberDiff line change
@@ -905,14 +905,21 @@ def add_atlan_tags(
905905
from pyatlan.client.atlan import AtlanClient
906906

907907
client = AtlanClient.get_current_client()
908-
909908
name_asset = client.asset.get_by_qualified_name(
910-
qualified_name=qualified_name, asset_type=asset_type
911-
)
912-
913-
updated_asset = asset_type.updater(
914-
qualified_name=qualified_name, name=name_asset.name
909+
qualified_name=qualified_name,
910+
asset_type=asset_type,
911+
ignore_relationships=False,
915912
)
913+
if asset_type in (AtlasGlossaryTerm, AtlasGlossaryCategory):
914+
updated_asset = asset_type.updater(
915+
qualified_name=qualified_name,
916+
name=name_asset.name,
917+
glossary_guid=name_asset.anchor.guid, # type: ignore
918+
)
919+
else:
920+
updated_asset = asset_type.updater(
921+
qualified_name=qualified_name, name=name_asset.name
922+
)
916923

917924
atlan_tag = [
918925
AtlanTag(
@@ -964,11 +971,20 @@ def update_atlan_tags(
964971

965972
client = AtlanClient.get_current_client()
966973
name_asset = client.asset.get_by_qualified_name(
967-
qualified_name=qualified_name, asset_type=asset_type
968-
)
969-
updated_asset = asset_type.updater(
970-
qualified_name=qualified_name, name=name_asset.name
974+
qualified_name=qualified_name,
975+
asset_type=asset_type,
976+
ignore_relationships=False,
971977
)
978+
if asset_type in (AtlasGlossaryTerm, AtlasGlossaryCategory):
979+
updated_asset = asset_type.updater(
980+
qualified_name=qualified_name,
981+
name=name_asset.name,
982+
glossary_guid=name_asset.anchor.guid, # type: ignore
983+
)
984+
else:
985+
updated_asset = asset_type.updater(
986+
qualified_name=qualified_name, name=name_asset.name
987+
)
972988

973989
atlan_tag = [
974990
AtlanTag(
@@ -1005,12 +1021,22 @@ def remove_atlan_tags(
10051021

10061022
client = AtlanClient.get_current_client()
10071023
name_asset = client.asset.get_by_qualified_name(
1008-
qualified_name=qualified_name, asset_type=asset_type
1009-
)
1010-
updated_asset = asset_type.updater(
1011-
qualified_name=qualified_name, name=name_asset.name
1024+
qualified_name=qualified_name,
1025+
asset_type=asset_type,
1026+
ignore_relationships=False,
10121027
)
10131028

1029+
if asset_type in (AtlasGlossaryTerm, AtlasGlossaryCategory):
1030+
updated_asset = asset_type.updater(
1031+
qualified_name=qualified_name,
1032+
name=name_asset.name,
1033+
glossary_guid=name_asset.anchor.guid, # type: ignore
1034+
)
1035+
else:
1036+
updated_asset = asset_type.updater(
1037+
qualified_name=qualified_name, name=name_asset.name
1038+
)
1039+
10141040
atlan_tag = [
10151041
AtlanTag(type_name=AtlanTagName(display_text=name))
10161042
for name in atlan_tag_names

testing.py

Lines changed: 0 additions & 28 deletions
This file was deleted.

0 commit comments

Comments
 (0)