We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent ce2098c commit b3bcb5dCopy full SHA for b3bcb5d
1 file changed
web/server/api/endpoints/lineage.py
@@ -67,6 +67,7 @@ async def column_lineage(
67
sources={
68
model: context.models[model].render_query()
69
for model in context.dag.upstream(model_name)
70
+ if model in context.models
71
},
72
)
73
except Exception:
@@ -84,9 +85,10 @@ async def column_lineage(
84
85
column_name = exp.to_column(node.name).name
86
if column_name in cache_column_names:
87
column_name = cache_column_names[column_name]
88
+ dialect = context.models[table].dialect if table in context.models else ""
89
graph[table] = {
90
column_name: LineageColumn(
- source=_get_node_source(node=node, dialect=context.models[table].dialect),
91
+ source=_get_node_source(node=node, dialect=dialect),
92
models=_process_downstream(
93
node.downstream,
94
column_name,
0 commit comments