yujunjun/OpenMetadata
1
0
Fork 0
mirror of https://github.com/open-metadata/OpenMetadata.git synced 2025-11-12 17:02:23 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix(kafkaconnect): update table search method to use search_in_any_service (#23852)

Browse Source
This commit is contained in:
Ayush Shah 2025-10-12 20:02:12 +05:30 committed by GitHub
parent 3801525263
commit d71a47db1d
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 8 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
ingestion/src/metadata/ingestion/source/pipeline/kafkaconnect/metadata.py
View File

@ -1244,9 +1244,11 @@ class KafkaconnectSource(PipelineServiceSource):
f"Searching for table with pattern: {search_pattern} " f"Searching for table with pattern: {search_pattern} "
f"(service={db_service_name}, schema={topic_info['database']}, table={topic_info['table']})" 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 current_dataset_entity = (
entity_type=Table, fqn_search_string=search_pattern self.metadata.search_in_any_service(
entity_type=Table,
fqn_search_string=search_pattern,
) )
) )
if current_dataset_entity: if current_dataset_entity:
@ -1278,8 +1280,9 @@ class KafkaconnectSource(PipelineServiceSource):
logger.info( logger.info(
f"Searching for table with pattern: {search_pattern}" 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, entity_type=Table,
fqn_search_string=search_pattern, fqn_search_string=search_pattern,
) )