diff --git a/ingestion/src/metadata/profiler/profiler.py b/ingestion/src/metadata/profiler/profiler.py index 7b383a94492..98a4b51bae5 100644 --- a/ingestion/src/metadata/profiler/profiler.py +++ b/ingestion/src/metadata/profiler/profiler.py @@ -354,7 +354,9 @@ class Profiler: boundary += bucket_width boundaries.append(round(boundary, 3)) - group_by_cte = get_group_by_cte(column_name, self.table.name) + group_by_cte = get_group_by_cte( + column_name, self.qualified_table_name + ) numeric_value_expr = get_group_by_cte_numeric_value_expression( column, self.database, None ) @@ -388,7 +390,6 @@ class Profiler: f" {fields} \n" f"FROM group_by_value" ) - row = self.database.execute_query(sql) self.queries_executed += 1