From 69d9cc07ee005e2867c08fd01222dfb05abb0b31 Mon Sep 17 00:00:00 2001 From: SumanMaharana Date: Mon, 9 Dec 2024 13:41:48 +0530 Subject: [PATCH] addressed comments --- .../ingestion/source/pipeline/kafkaconnect/client.py | 8 ++------ 1 file changed, 2 insertions(+), 6 deletions(-) diff --git a/ingestion/src/metadata/ingestion/source/pipeline/kafkaconnect/client.py b/ingestion/src/metadata/ingestion/source/pipeline/kafkaconnect/client.py index 3390d500b67c..3c2b266d004e 100644 --- a/ingestion/src/metadata/ingestion/source/pipeline/kafkaconnect/client.py +++ b/ingestion/src/metadata/ingestion/source/pipeline/kafkaconnect/client.py @@ -61,8 +61,7 @@ def get_cluster_info(self) -> Optional[dict]: """ Get the version and other details of the Kafka Connect cluster. """ - result = self.client.get_cluster_info() - return result + return self.client.get_cluster_info() def get_connectors_list( self, @@ -73,10 +72,7 @@ def get_connectors_list( """ Get the list of connectors from Kafka Connect cluster. """ - result = self.client.list_connectors( - expand=expand, pattern=pattern, state=state - ) - return result + return self.client.list_connectors(expand=expand, pattern=pattern, state=state) def get_connectors( self,