From 279f9eb455d6e8cf30264b52d94ff91c9e4c06e4 Mon Sep 17 00:00:00 2001 From: Tamas Nemeth Date: Tue, 6 Jun 2023 11:17:14 +0200 Subject: [PATCH] fix(ingest/kafka): Fixing error printing in Kafka properties get call (#8145) --- metadata-ingestion/src/datahub/ingestion/source/kafka.py | 2 -- 1 file changed, 2 deletions(-) diff --git a/metadata-ingestion/src/datahub/ingestion/source/kafka.py b/metadata-ingestion/src/datahub/ingestion/source/kafka.py index 420a4aa010..7bcd775bd9 100644 --- a/metadata-ingestion/src/datahub/ingestion/source/kafka.py +++ b/metadata-ingestion/src/datahub/ingestion/source/kafka.py @@ -416,8 +416,6 @@ class KafkaSource(StatefulIngestionSourceBase): topic_configurations: dict, ) -> None: try: - assert config_result_future.done() - assert config_result_future.exception() is None topic_configurations[config_resource.name] = config_result_future.result() except Exception as e: logger.warning(