Remove unneded code

Author: treff7es

metadata-ingestion/src/datahub/ingestion/source/kafka_connect/common.py

@@ -387,26 +387,6 @@ class ConnectorManifest:
     lineages: List[KafkaConnectLineage] = field(default_factory=list)
     topic_names: List[str] = field(default_factory=list)
 
-    def extract_lineages(
-        self, config: "KafkaConnectSourceConfig", report: "KafkaConnectSourceReport"
-    ) -> List[KafkaConnectLineage]:
-        """Extract lineages for this connector using connector registry."""
-        from datahub.ingestion.source.kafka_connect.connector_registry import (
-            ConnectorRegistry,
-        )
-
-        return ConnectorRegistry.extract_lineages(self, config, report)
-
-    def extract_flow_property_bag(
-        self, config: "KafkaConnectSourceConfig", report: "KafkaConnectSourceReport"
-    ) -> Optional[Dict[str, str]]:
-        """Extract flow property bag for this connector using connector registry."""
-        from datahub.ingestion.source.kafka_connect.connector_registry import (
-            ConnectorRegistry,
-        )
-
-        return ConnectorRegistry.extract_flow_property_bag(self, config, report)
-
     def get_topics_from_config(
         self, config: "KafkaConnectSourceConfig", report: "KafkaConnectSourceReport"
     ) -> List[str]:

metadata-ingestion/src/datahub/ingestion/source/kafka_connect/connector_registry.py

@@ -5,7 +5,7 @@
 """
 
 import logging
-from typing import TYPE_CHECKING, Dict, List, Optional
+from typing import TYPE_CHECKING, List, Optional
 
 from datahub.ingestion.source.kafka_connect.common import (
     CLOUD_JDBC_SOURCE_CLASSES,
@@ -213,34 +213,6 @@ def _get_sink_connector(
 
         return None
 
-    @staticmethod
-    def extract_lineages(
-        manifest: ConnectorManifest,
-        config: KafkaConnectSourceConfig,
-        report: KafkaConnectSourceReport,
-    ) -> List[KafkaConnectLineage]:
-        """Extract lineages using the appropriate connector."""
-        connector = ConnectorRegistry.get_connector_for_manifest(
-            manifest, config, report
-        )
-        if connector:
-            return connector.extract_lineages()
-        return []
-
-    @staticmethod
-    def extract_flow_property_bag(
-        manifest: ConnectorManifest,
-        config: KafkaConnectSourceConfig,
-        report: KafkaConnectSourceReport,
-    ) -> Optional[Dict[str, str]]:
-        """Extract flow property bag using the appropriate connector."""
-        connector = ConnectorRegistry.get_connector_for_manifest(
-            manifest, config, report
-        )
-        if connector:
-            return connector.extract_flow_property_bag()
-        return None
-
     @staticmethod
     def get_topics_from_config(
         manifest: ConnectorManifest,

metadata-ingestion/src/datahub/ingestion/source/kafka_connect/source_connectors.py

@@ -1067,14 +1067,8 @@ def _derive_topics_from_config(self) -> List[str]:
         """Extract topics directly from connector configuration - most reliable approach."""
         config = self.connector_manifest.config
 
-        # Use the connector registry for configuration-based topic derivation
-        from datahub.ingestion.source.kafka_connect.connector_registry import (
-            ConnectorRegistry,
-        )
-
-        config_topics = ConnectorRegistry.get_topics_from_config(
-            self.connector_manifest, self.config, self.report
-        )
+        # Call own get_topics_from_config method directly to avoid creating new instance
+        config_topics = self.get_topics_from_config()
 
         if config_topics:
             # Apply predictable transforms to get final topic names