diff --git a/ingestion/src/metadata/ingestion/source/database/postgres_lineage.py b/ingestion/src/metadata/ingestion/source/database/postgres_lineage.py index 2283b9ea8da..ef975186188 100644 --- a/ingestion/src/metadata/ingestion/source/database/postgres_lineage.py +++ b/ingestion/src/metadata/ingestion/source/database/postgres_lineage.py @@ -32,8 +32,8 @@ class PostgresLineageSource(PostgresQueryParserSource, LineageSource): filters = """ AND ( - s.query ILIKE '%%create table %% as select %%' - OR s.query ILIKE '%%insert %%' + s.query ILIKE '%%create table%%as%%select%%' + OR s.query ILIKE '%%insert%%' ) """ diff --git a/ingestion/src/metadata/ingestion/source/database/redshift_lineage.py b/ingestion/src/metadata/ingestion/source/database/redshift_lineage.py index c9f205d87b5..6bf7846e3bb 100644 --- a/ingestion/src/metadata/ingestion/source/database/redshift_lineage.py +++ b/ingestion/src/metadata/ingestion/source/database/redshift_lineage.py @@ -41,8 +41,8 @@ class RedshiftLineageSource(RedshiftQueryParserSource, LineageSource): filters = """ AND ( - querytxt ILIKE 'create table %% as select %%' - OR querytxt ILIKE 'insert %%' + querytxt ILIKE '%%create table%%as%%select%%' + OR querytxt ILIKE '%%insert%%' ) """ diff --git a/ingestion/src/metadata/ingestion/source/database/redshift_usage.py b/ingestion/src/metadata/ingestion/source/database/redshift_usage.py index b01a8939734..a746b5e5af2 100644 --- a/ingestion/src/metadata/ingestion/source/database/redshift_usage.py +++ b/ingestion/src/metadata/ingestion/source/database/redshift_usage.py @@ -25,8 +25,8 @@ class RedshiftUsageSource(RedshiftQueryParserSource, UsageSource): AND querytxt NOT ILIKE 'fetch %%' AND querytxt NOT ILIKE 'padb_fetch_sample: %%' AND querytxt NOT ILIKE 'Undoing %% transactions on table %% with current xid%%' - AND querytxt NOT ILIKE 'create table %% as select %%' - AND querytxt NOT ILIKE 'insert %%' + AND querytxt NOT ILIKE '%%create table%%as%%select%%' + AND querytxt NOT ILIKE '%%insert%%' """ sql_stmt = REDSHIFT_SQL_STATEMENT