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,