From b10218f772b9de6b7f9948019899f9589c116a63 Mon Sep 17 00:00:00 2001
From: ehddnr301 <dy950328@gmail.com>
Date: Sun, 6 Jul 2025 02:27:59 +0000
Subject: [PATCH] =?UTF-8?q?feat:=20=EB=8D=B0=EC=9D=B4=ED=84=B0=EC=85=8B=20?=
 =?UTF-8?q?=EC=9D=B4=EB=A6=84=EC=97=90=20=EB=8D=B0=EC=9D=B4=ED=84=B0?=
 =?UTF-8?q?=EB=B2=A0=EC=9D=B4=EC=8A=A4=20=EC=A0=95=EB=B3=B4=EB=A5=BC=20?=
 =?UTF-8?q?=EC=B6=94=EA=B0=80=ED=95=98=EC=97=AC=20=EB=B0=98=ED=99=98=20?=
 =?UTF-8?q?=ED=98=95=EC=8B=9D=20=EA=B0=9C=EC=84=A0?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

- DatahubMetadataFetcher 클래스에서 데이터셋의 이름에 dbt_unique_id를 포함하여 반환하도록 수정
- 데이터베이스 정보와 테이블 정보를 결합하여 반환 형식 개선
---
 data_utils/datahub_source.py | 10 +++++++++-
 1 file changed, 9 insertions(+), 1 deletion(-)

diff --git a/data_utils/datahub_source.py b/data_utils/datahub_source.py
index 9be2c7d..079a8c2 100644
--- a/data_utils/datahub_source.py
+++ b/data_utils/datahub_source.py
@@ -47,7 +47,15 @@ def get_table_name(self, urn):
             urn, aspect_type=DatasetPropertiesClass
         )
         if dataset_properties:
-            return dataset_properties.get("name", None)
+            database_info = dataset_properties.get("customProperties", {}).get(
+                "dbt_unique_id", ""
+            )
+            if database_info:
+                database_info = database_info.split(".")[-2]
+            else:
+                database_info = ""
+            table_info = dataset_properties.get("name", None)
+            return database_info + "." + table_info
         return None
 
     def get_table_description(self, urn):