diff --git a/metadata-ingestion/src/datahub/ingestion/source/snowflake/snowflake_query.py b/metadata-ingestion/src/datahub/ingestion/source/snowflake/snowflake_query.py
index 0c08cb0062dbb..66fcd0c32fa1c 100644
--- 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