diff --git a/ingestion/src/metadata/ingestion/source/sql_source.py b/ingestion/src/metadata/ingestion/source/sql_source.py
index 2bee39d206f..461233553b4 100644
--- a/ingestion/src/metadata/ingestion/source/sql_source.py
+++ b/ingestion/src/metadata/ingestion/source/sql_source.py
@@ -564,7 +564,11 @@ class SQLSource(Source[OMetaDatabaseAndTable]):
                             ]
                         col_dict = Column(**parsed_string)
                         try:
-                            if "policy_tags" in column and column["policy_tags"]:
+                            if (
+                                self.config.enable_policy_tags
+                                and "policy_tags" in column
+                                and column["policy_tags"]
+                            ):
                                 self.metadata.create_primary_tag_category(
                                     category=self.config.tag_category_name,
                                     data=Tag(
@@ -572,7 +576,7 @@ class SQLSource(Source[OMetaDatabaseAndTable]):
                                     ),
                                 )
                         except APIError:
-                            if column["policy_tags"]:
+                            if column["policy_tags"] and self.config.enable_policy_tags:
                                 col_dict.tags = [
                                     TagLabel(
                                         tagFQN=f"{self.config.tag_category_name}.{column['policy_tags']}",
@@ -581,9 +585,8 @@ class SQLSource(Source[OMetaDatabaseAndTable]):
                                     )
                                 ]
                         except Exception as err:
-                            logger.error(traceback.print_exc())
-                            logger.error(err)
-
+                            logger.debug(traceback.print_exc())
+                            logger.debug(err)
                         om_column = col_dict
                 except Exception as err:
                     logger.debug(traceback.print_exc())