diff --git a/ingestion/src/metadata/ingestion/source/sql_source.py b/ingestion/src/metadata/ingestion/source/sql_source.py index 70f192b0ac1..65931beb8fb 100644 --- a/ingestion/src/metadata/ingestion/source/sql_source.py +++ b/ingestion/src/metadata/ingestion/source/sql_source.py @@ -621,7 +621,9 @@ class SQLSource(Source[OMetaDatabaseAndTable]): unique_columns.extend(constraint.get("column_names")) table_columns = [] - columns = inspector.get_columns(table, schema, db_name=self.service_connection.database) + columns = inspector.get_columns( + table, schema, db_name=self.service_connection.database + ) try: for column in columns: try: