diff --git a/ingestion/src/metadata/ingestion/source/dashboard/superset/db_source.py b/ingestion/src/metadata/ingestion/source/dashboard/superset/db_source.py
index 83833689fbd..c5d09684792 100644
--- a/ingestion/src/metadata/ingestion/source/dashboard/superset/db_source.py
+++ b/ingestion/src/metadata/ingestion/source/dashboard/superset/db_source.py
@@ -15,7 +15,6 @@ Superset source module
 import traceback
 from typing import Iterable, Optional
 
-from sqlalchemy import sql
 from sqlalchemy.engine import Engine
 from sqlalchemy.engine.url import make_url
 
@@ -87,7 +86,7 @@ class SupersetDBSource(SupersetSourceMixin):
         try:
             if table_name:
                 col_list = self.engine.execute(
-                    sql.text(FETCH_COLUMN), table_name=table_name.lower()
+                    FETCH_COLUMN, table_name=table_name.lower()
                 )
                 return [FetchColumn(**col) for col in col_list]
         except Exception as err:
diff --git a/ingestion/src/metadata/ingestion/source/dashboard/superset/queries.py b/ingestion/src/metadata/ingestion/source/dashboard/superset/queries.py
index 373045d10ee..eeec1082cbd 100644
--- a/ingestion/src/metadata/ingestion/source/dashboard/superset/queries.py
+++ b/ingestion/src/metadata/ingestion/source/dashboard/superset/queries.py
@@ -85,5 +85,5 @@ inner join
 on 
 	t.id=tc.table_id  
 where 
-	table_name= %(table_name)s
+	table_name=%(table_name)s
 """