From d71a47db1db43eb7a4447152a9d2b9e34fb0811e Mon Sep 17 00:00:00 2001 From: Ayush Shah Date: Sun, 12 Oct 2025 20:02:12 +0530 Subject: [PATCH] fix(kafkaconnect): update table search method to use search_in_any_service (#23852) --- .../source/pipeline/kafkaconnect/metadata.py | 13 ++++++++----- 1 file changed, 8 insertions(+), 5 deletions(-) diff --git a/ingestion/src/metadata/ingestion/source/pipeline/kafkaconnect/metadata.py b/ingestion/src/metadata/ingestion/source/pipeline/kafkaconnect/metadata.py index 3d4569732ff..9901e2b5939 100644 --- a/ingestion/src/metadata/ingestion/source/pipeline/kafkaconnect/metadata.py +++ b/ingestion/src/metadata/ingestion/source/pipeline/kafkaconnect/metadata.py @@ -1244,9 +1244,11 @@ class KafkaconnectSource(PipelineServiceSource): f"Searching for table with pattern: {search_pattern} " f"(service={db_service_name}, schema={topic_info['database']}, table={topic_info['table']})" ) - current_dataset_entity = self.metadata.get_by_name( - entity=Table, fqn=search_pattern - entity_type=Table, fqn_search_string=search_pattern + + current_dataset_entity = ( + self.metadata.search_in_any_service( + entity_type=Table, + fqn_search_string=search_pattern, ) ) if current_dataset_entity: @@ -1278,8 +1280,9 @@ class KafkaconnectSource(PipelineServiceSource): logger.info( f"Searching for table with pattern: {search_pattern}" ) - current_dataset_entity = self.metadata.get_by_name( - entity=Table, fqn=search_pattern + + current_dataset_entity = ( + self.metadata.search_in_any_service( entity_type=Table, fqn_search_string=search_pattern, )