From b7555806fd28e4db1e17f7ebfd8bbef810044cf7 Mon Sep 17 00:00:00 2001 From: Onkar Ravgan Date: Tue, 10 May 2022 16:35:36 +0530 Subject: [PATCH] removed unused imports (#4837) Co-authored-by: Onkar Ravgan --- ingestion/src/metadata/ingestion/source/kafka.py | 2 -- 1 file changed, 2 deletions(-) diff --git a/ingestion/src/metadata/ingestion/source/kafka.py b/ingestion/src/metadata/ingestion/source/kafka.py index d2619b4d36b..23fdb54cfb9 100644 --- a/ingestion/src/metadata/ingestion/source/kafka.py +++ b/ingestion/src/metadata/ingestion/source/kafka.py @@ -49,11 +49,9 @@ from metadata.generated.schema.type.entityReference import EntityReference from metadata.ingestion.api.common import logger from metadata.ingestion.api.source import InvalidSourceException, Source, SourceStatus from metadata.ingestion.ometa.ometa_api import OpenMetadata -from metadata.ingestion.ometa.utils import exit_after from metadata.utils.connection_clients import KafkaClient from metadata.utils.connections import get_connection, test_connection from metadata.utils.filters import filter_by_topic -from metadata.utils.helpers import get_messaging_service_or_create @dataclass