diff --git a/ingestion/src/metadata/ingestion/source/database/bigquery/lineage.py b/ingestion/src/metadata/ingestion/source/database/bigquery/lineage.py index 0630a6d26a8..3a3f8d71430 100644 --- a/ingestion/src/metadata/ingestion/source/database/bigquery/lineage.py +++ b/ingestion/src/metadata/ingestion/source/database/bigquery/lineage.py @@ -42,6 +42,7 @@ class BigqueryLineageSource( AND ( statement_type IN ("MERGE", "CREATE_TABLE_AS_SELECT", "UPDATE") OR (statement_type = "INSERT" and UPPER(query) like '%%INSERT%%INTO%%SELECT%%') + OR (statement_type = "CREATE_TABLE" and UPPER(query) like '%%CLONE%%') ) """