diff --git a/ingestion/src/metadata/ingestion/source/dashboard/powerbi/client.py b/ingestion/src/metadata/ingestion/source/dashboard/powerbi/client.py
index d3a4b708282..246e56d8604 100644
--- a/ingestion/src/metadata/ingestion/source/dashboard/powerbi/client.py
+++ b/ingestion/src/metadata/ingestion/source/dashboard/powerbi/client.py
@@ -47,6 +47,7 @@ from metadata.utils.logger import utils_logger
 
 logger = utils_logger()
 
+
 # Similar inner methods with mode client. That's fine.
 # pylint: disable=duplicate-code
 class PowerBiApiClient:
diff --git a/ingestion/src/metadata/ingestion/source/database/dbt/metadata.py b/ingestion/src/metadata/ingestion/source/database/dbt/metadata.py
index b133ef7e750..5e8a709739b 100644
--- a/ingestion/src/metadata/ingestion/source/database/dbt/metadata.py
+++ b/ingestion/src/metadata/ingestion/source/database/dbt/metadata.py
@@ -394,11 +394,14 @@ class DbtSource(DbtServiceSource):
 
                     dbt_table_tags_list = []
                     if manifest_node.tags:
-                        dbt_table_tags_list = get_tag_labels(
-                            metadata=self.metadata,
-                            tags=manifest_node.tags,
-                            classification_name=self.tag_classification_name,
-                            include_tags=self.source_config.includeTags,
+                        dbt_table_tags_list = (
+                            get_tag_labels(
+                                metadata=self.metadata,
+                                tags=manifest_node.tags,
+                                classification_name=self.tag_classification_name,
+                                include_tags=self.source_config.includeTags,
+                            )
+                            or []
                         )
 
                     if manifest_node.meta:
diff --git a/ingestion/src/metadata/ingestion/source/messaging/kafka/metadata.py b/ingestion/src/metadata/ingestion/source/messaging/kafka/metadata.py
index 7c8e7abf257..f6f11d070fd 100644
--- a/ingestion/src/metadata/ingestion/source/messaging/kafka/metadata.py
+++ b/ingestion/src/metadata/ingestion/source/messaging/kafka/metadata.py
@@ -30,7 +30,6 @@ class KafkaSource(CommonBrokerSource):
         self.ssl_manager = None
         service_connection = cast(KafkaConnection, config.serviceConnection.root.config)
         if service_connection.schemaRegistrySSL:
-
             self.ssl_manager = SSLManager(
                 ca=service_connection.schemaRegistrySSL.root.caCertificate,
                 key=service_connection.schemaRegistrySSL.root.sslKey,
diff --git a/ingestion/src/metadata/ingestion/source/pipeline/databrickspipeline/metadata.py b/ingestion/src/metadata/ingestion/source/pipeline/databrickspipeline/metadata.py
index de6b56daf48..99e8710c9a1 100644
--- a/ingestion/src/metadata/ingestion/source/pipeline/databrickspipeline/metadata.py
+++ b/ingestion/src/metadata/ingestion/source/pipeline/databrickspipeline/metadata.py
@@ -99,7 +99,6 @@ class DatabrickspipelineSource(PipelineServiceSource):
         """Method to Get Pipeline Entity"""
         self.context.get().job_id_list = []
         try:
-
             description = pipeline_details["settings"].get("name")
             pipeline_request = CreatePipelineRequest(
                 name=EntityName(str(pipeline_details["job_id"])),
diff --git a/ingestion/src/metadata/ingestion/source/pipeline/kafkaconnect/metadata.py b/ingestion/src/metadata/ingestion/source/pipeline/kafkaconnect/metadata.py
index 086c3030acc..620f2416033 100644
--- a/ingestion/src/metadata/ingestion/source/pipeline/kafkaconnect/metadata.py
+++ b/ingestion/src/metadata/ingestion/source/pipeline/kafkaconnect/metadata.py
@@ -201,7 +201,6 @@ class KafkaconnectSource(PipelineServiceSource):
             dataset_entity = self.get_dataset_entity(pipeline_details=pipeline_details)
 
             for topic in pipeline_details.topics or []:
-
                 topic_fqn = fqn.build(
                     metadata=self.metadata,
                     entity_type=Topic,
diff --git a/ingestion/tests/integration/containers.py b/ingestion/tests/integration/containers.py
index 3599fd30aca..9483f2468a4 100644
--- a/ingestion/tests/integration/containers.py
+++ b/ingestion/tests/integration/containers.py
@@ -70,7 +70,6 @@ def get_docker_network(name: str):
 
 
 def get_mysql_container(mysql_config: MySqlContainerConfigs):
-
     container = MySqlContainer(
         **{
             k: v
diff --git a/ingestion/tests/integration/mlflow/test_mlflow.py b/ingestion/tests/integration/mlflow/test_mlflow.py
index 70fe730f84d..7c7907799db 100644
--- a/ingestion/tests/integration/mlflow/test_mlflow.py
+++ b/ingestion/tests/integration/mlflow/test_mlflow.py
@@ -113,7 +113,6 @@ def create_data(mlflow_environment):
 
         # Model registry does not work with file store
         if tracking_url_type_store != "file":
-
             # Register the model
             # There are other ways to use the Model Registry, which depends on the use case,
             # please refer to the doc for more information: