yujunjun/OpenMetadata
1
0
Fork 0
mirror of https://github.com/open-metadata/OpenMetadata.git synced 2025-09-23 07:51:44 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fixed pipeline FQN bug (#7740)

Browse Source 
* Fixed pipeline FQN

* fixed messaging service

Co-authored-by: Onkar Ravgan <onkarravgan@Onkars-MacBook-Pro.local>
This commit is contained in:
Onkar Ravgan 2022-09-27 14:23:59 +05:30 committed by GitHub
parent 09855fc4c1
commit dc74089f0e
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
ingestion/src/metadata/ingestion/source/messaging/messaging_service.py
View File

@ -152,7 +152,7 @@ class MessagingServiceSource(TopologyRunnerMixin, Source, ABC):
self.metadata, self.metadata,
entity_type=Topic, entity_type=Topic,
service_name=self.context.messaging_service.name.__root__, service_name=self.context.messaging_service.name.__root__,
mlmodel_name=self.get_topic_name(topic_details), topic_name=self.get_topic_name(topic_details),
) )
if filter_by_topic( if filter_by_topic(
self.source_config.topicFilterPattern, self.source_config.topicFilterPattern,

2
ingestion/src/metadata/ingestion/source/pipeline/pipeline_service.py
View File

@ -211,7 +211,7 @@ class PipelineServiceSource(TopologyRunnerMixin, Source, ABC):
self.metadata, self.metadata,
entity_type=Pipeline, entity_type=Pipeline,
service_name=self.context.pipeline_service.name.__root__, service_name=self.context.pipeline_service.name.__root__,
mlmodel_name=self.get_pipeline_name(pipeline_detail), pipeline_name=self.get_pipeline_name(pipeline_detail),
) )
if filter_by_pipeline( if filter_by_pipeline(
self.source_config.pipelineFilterPattern, self.source_config.pipelineFilterPattern,