Skip to content

Commit 9589538

Browse files
committed
chore : build_table_metadata 함수 조회하는 테이블 downstream에서 제외
1 parent 888a62f commit 9589538

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

data_utils/datahub_source.py

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -258,12 +258,13 @@ def process_lineage(direction):
258258
# 테이블 lineage 가져오기
259259
lineage_result = self.get_table_lineage(urn, direction=direction)
260260
table_degrees = self.min_degree_lineage(lineage_result)
261+
current_table_name = metadata["table_name"]
261262

262263
# degree 필터링
263264
filtered_lineage = [
264265
{"table": table, "degree": degree}
265266
for table, degree in table_degrees.items()
266-
if degree <= max_degree
267+
if degree <= max_degree and table != current_table_name
267268
]
268269

269270
# degree 기준 정렬

0 commit comments

Comments
 (0)