Skip to content

Commit 8f53dd9

Browse files
author
Abdullah Tariq
committed
fix: apply proposed changes
1 parent d702148 commit 8f53dd9

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

metadata-ingestion/src/datahub/ingestion/source/dbt/dbt_common.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1133,8 +1133,8 @@ def add_node_to_cll_list(dbt_name: str) -> None:
11331133
cll_nodes.add(dbt_name)
11341134
schema_nodes.add(dbt_name)
11351135

1136-
for dbt_name in all_nodes_map:
1137-
if self._is_allowed_node(all_nodes_map.get(dbt_name)):
1136+
for dbt_name, dbt_node in all_nodes_map.items():
1137+
if self._is_allowed_node(dbt_node):
11381138
add_node_to_cll_list(dbt_name)
11391139

11401140
return schema_nodes, cll_nodes

0 commit comments

Comments
 (0)