diff --git a/metadata-ingestion/src/datahub/ingestion/source/sql_queries.py b/metadata-ingestion/src/datahub/ingestion/source/sql_queries.py index 2fe9ace111d6fb..b38c4080397f08 100644 --- a/metadata-ingestion/src/datahub/ingestion/source/sql_queries.py +++ b/metadata-ingestion/src/datahub/ingestion/source/sql_queries.py @@ -182,7 +182,7 @@ def _process_query(self, entry: "QueryEntry") -> Iterable[MetadataWorkUnit]: schema_resolver=self.schema_resolver, default_db=self.config.default_db, default_schema=self.config.default_schema, - default_dialect=self.config.default_dialect, + default_dialect=self.config.default_dialect, ) if result.debug_info.table_error: logger.info(f"Error parsing table lineage, {result.debug_info.table_error}")