fix(ingest/snowflake): handle column level lineage for dbt temporary …

…tables (datahub-project#10258)

Co-authored-by: Harshal Sheth <[email protected]>

metadata-ingestion/src/datahub/ingestion/source/snowflake/snowflake_query.py

@@ -781,7 +781,7 @@ def table_upstreams_with_column_lineage(
             SELECT
                 r.value : "objectName" :: varchar AS upstream_table_name,
                 r.value : "objectDomain" :: varchar AS upstream_table_domain,
-                w.value : "objectName" :: varchar AS downstream_table_name,
+                REPLACE(w.value : "objectName" :: varchar, '__DBT_TMP', '') AS downstream_table_name,
                 w.value : "objectDomain" :: varchar AS downstream_table_domain,
                 wcols.value : "columnName" :: varchar AS downstream_column_name,
                 wcols_directSources.value : "objectName" as upstream_column_table_name,