diff --git a/metadata-ingestion/src/datahub/sql_parsing/sqlglot_utils.py b/metadata-ingestion/src/datahub/sql_parsing/sqlglot_utils.py index f74a915c9fe821..56e4c806eb0c30 100644 --- a/metadata-ingestion/src/datahub/sql_parsing/sqlglot_utils.py +++ b/metadata-ingestion/src/datahub/sql_parsing/sqlglot_utils.py @@ -66,7 +66,7 @@ def _parse_statement( sql: sqlglot.exp.ExpOrStr, dialect: sqlglot.Dialect ) -> sqlglot.Expression: statement: sqlglot.Expression = sqlglot.maybe_parse( - sql, dialect=dialect, error_level=sqlglot.ErrorLevel.RAISE + sql, dialect=dialect, error_level=sqlglot.ErrorLevel.IMMEDIATE ) return statement