Skip to content

Commit db6e22c

Browse files
Merge branch 'main' into copilot/add-hyperlink-support
2 parents 024e914 + 57d4aec commit db6e22c

File tree

34 files changed

+2293
-498
lines changed

34 files changed

+2293
-498
lines changed

ingestion/src/metadata/utils/fqn.py

Lines changed: 17 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -405,11 +405,16 @@ def _(
405405
)
406406

407407
if not entity and service_name and container_name:
408-
fqn = (
409-
_build(service_name, parent_container, container_name, quote=False)
410-
if parent_container
411-
else _build(service_name, container_name)
412-
)
408+
if parent_container:
409+
# Check if parent_container already starts with service_name
410+
if parent_container.startswith(f"{service_name}."):
411+
fqn = _build(parent_container, container_name, quote=False)
412+
else:
413+
fqn = _build(
414+
service_name, parent_container, container_name, quote=False
415+
)
416+
else:
417+
fqn = _build(service_name, container_name)
413418
return [fqn] if fetch_multiple_entities else fqn
414419
if entity and fetch_multiple_entities:
415420
return [str(container.fullyQualifiedName.root) for container in entity]
@@ -898,9 +903,13 @@ def search_container_from_es(
898903
)
899904

900905
if parent_container:
901-
fqn_search_string = _build(
902-
service_name or "*", parent_container, container_name, quote=False
903-
)
906+
# Check if parent_container already starts with service_name
907+
if service_name and parent_container.startswith(f"{service_name}."):
908+
fqn_search_string = _build(parent_container, container_name, quote=False)
909+
else:
910+
fqn_search_string = _build(
911+
service_name or "*", parent_container, container_name, quote=False
912+
)
904913
else:
905914
fqn_search_string = _build(service_name or "*", container_name)
906915

0 commit comments

Comments
 (0)