lint

asikowitz · Aug 28, 2023 · ef6446d · ef6446d
1 parent b76f2ab
commit ef6446d
Show file tree

Hide file tree

Showing 3 changed files with 2 additions and 4 deletions.
diff --git 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
@@ -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
@@ -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,