diff --git a/metadata-ingestion/src/datahub/ingestion/source/datahub/config.py b/metadata-ingestion/src/datahub/ingestion/source/datahub/config.py
index f05b5db912cb9..efefe1b35c3b3 100644
--- a/metadata-ingestion/src/datahub/ingestion/source/datahub/config.py
+++ b/metadata-ingestion/src/datahub/ingestion/source/datahub/config.py
@@ -3,7 +3,6 @@
 from pydantic import Field
 
 from datahub.configuration.kafka import KafkaConsumerConnectionConfig
-from datahub.ingestion.source.sql.mysql import MySQLConnectionConfig
 from datahub.ingestion.source.sql.sql_config import SQLAlchemyConnectionConfig
 from datahub.ingestion.source.state.stateful_ingestion_base import (
     StatefulIngestionConfig,
diff --git a/metadata-ingestion/src/datahub/ingestion/source/datahub/datahub_source.py b/metadata-ingestion/src/datahub/ingestion/source/datahub/datahub_source.py
index 61207712341fe..2368febe1ff57 100644
--- a/metadata-ingestion/src/datahub/ingestion/source/datahub/datahub_source.py
+++ b/metadata-ingestion/src/datahub/ingestion/source/datahub/datahub_source.py
@@ -106,7 +106,7 @@ def _get_kafka_workunits(
         if self.config.kafka_connection is None:
             return
 
-        logger.info(f"Fetching timeseries aspects from kafka")
+        logger.info("Fetching timeseries aspects from kafka")
         with DataHubKafkaReader(
             self.config, self.config.kafka_connection, self.report, self.ctx
         ) as reader:
diff --git a/metadata-ingestion/src/datahub/ingestion/source/datahub/report.py b/metadata-ingestion/src/datahub/ingestion/source/datahub/report.py
index bd0a0aedaccd3..73e5a798a1553 100644
--- a/metadata-ingestion/src/datahub/ingestion/source/datahub/report.py
+++ b/metadata-ingestion/src/datahub/ingestion/source/datahub/report.py
@@ -1,6 +1,5 @@
-from datetime import timezone, datetime
-
 from dataclasses import dataclass, field
+from datetime import datetime, timezone
 
 from datahub.ingestion.source.state.stateful_ingestion_base import (
     StatefulIngestionReport,