Merge pull request #606 from atlanhq/APP-5774

APP-5774 : Extend tagged with value search with option for specific source tag

Author: Aryamanz29

pyatlan/model/fluent_search.py

@@ -151,7 +151,10 @@ def tagged(
 
     @staticmethod
     def tagged_with_value(
-        atlan_tag_name: str, value: str, directly: bool = False
+        atlan_tag_name: str,
+        value: str,
+        directly: bool = False,
+        source_tag_qualified_name: Optional[str] = None,
     ) -> Query:
         """
         Returns a query that will match assets that have a
@@ -161,7 +164,8 @@ def tagged_with_value(
         :param value: tag should have to match the query
         :param directly: when `True`, the asset must have the tag and
         value directly assigned (otherwise even propagated tags with the value will suffice)
-
+        :param source_tag_qualified_name: (optional) qualified name of
+        the source tag to match (when there are multiple)
         :raises: AtlanError on any error communicating
         with the API to refresh the Atlan tag cache
         :returns: a query that will only match assets that have
@@ -182,17 +186,18 @@ def tagged_with_value(
                 .execute(client=client)
             )
         ]
-        if len(synced_tags) > 1:
+        if len(synced_tags) > 1 and source_tag_qualified_name is None:
             synced_tag_qn = synced_tags[0].qualified_name or ""
             LOGGER.warning(
-                (
-                    "Multiple mapped source-synced tags found for tag %s -- using only the first: %s",
-                ),
+                "Multiple mapped source-synced tags found for tag %s -- using only the first: %s. "
+                "You can specify the `source_tag_qualified_name` so we can match to the specific one.",
                 atlan_tag_name,
                 synced_tag_qn,
             )
         elif synced_tags:
-            synced_tag_qn = synced_tags[0].qualified_name or ""
+            synced_tag_qn = (
+                source_tag_qualified_name or synced_tags[0].qualified_name or ""
+            )
         else:
             synced_tag_qn = "NON_EXISTENT"