fix(ingest/snowflake): fix column name in snowflake optimised lineage (…

…#7834)
datahub-project · Apr 17, 2023 · a8681da · a8681da
1 parent ed85296
commit a8681da
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/metadata-ingestion/src/datahub/ingestion/source/snowflake/snowflake_query.py b/metadata-ingestion/src/datahub/ingestion/source/snowflake/snowflake_query.py
@@ -693,7 +693,7 @@ def table_upstreams_with_column_lineage(
                 lateral flatten(input => t.DIRECT_OBJECTS_ACCESSED) r,
                 lateral flatten(input => t.OBJECTS_MODIFIED) w,
                 lateral flatten(input => w.value : "columns", outer => true) wcols,
-                lateral flatten(input => wcols.value : "directSourceColumns", outer => true) wcols_directSources
+                lateral flatten(input => wcols.value : "directSources", outer => true) wcols_directSources
             WHERE
                 r.value : "objectId" IS NOT NULL
                 AND w.value : "objectId" IS NOT NULL