diff --git a/ingestion/src/metadata/ingestion/source/database/usage_source.py b/ingestion/src/metadata/ingestion/source/database/usage_source.py
index b0a23a66375..0e0993cc296 100644
--- a/ingestion/src/metadata/ingestion/source/database/usage_source.py
+++ b/ingestion/src/metadata/ingestion/source/database/usage_source.py
@@ -122,15 +122,15 @@ class UsageSource(QueryParserSource, ABC):
                             row = dict(row)
                             try:
                                 row.update({k.lower(): v for k, v in row.items()})
-                                logger.debug(f"Processing row: {query}")
+                                logger.debug(f"Processing row: {row}")
                                 query_type = row.get("query_type")
-                                query = self.format_query(row["query_text"])
+                                query_text = self.format_query(row["query_text"])
                                 queries.append(
                                     TableQuery(
-                                        query=query,
+                                        query=query_text,
                                         query_type=query_type,
                                         exclude_usage=self.check_life_cycle_query(
-                                            query_type=query_type, query_text=query
+                                            query_type=query_type, query_text=query_text
                                         ),
                                         dialect=self.dialect.value,
                                         userName=row["user_name"],