diff --git a/ingestion/src/metadata/ingestion/source/messaging/messaging_service.py b/ingestion/src/metadata/ingestion/source/messaging/messaging_service.py
index b1944d8aaf8..33cbb5c0f57 100644
--- a/ingestion/src/metadata/ingestion/source/messaging/messaging_service.py
+++ b/ingestion/src/metadata/ingestion/source/messaging/messaging_service.py
@@ -152,7 +152,7 @@ class MessagingServiceSource(TopologyRunnerMixin, Source, ABC):
                 self.metadata,
                 entity_type=Topic,
                 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(
                 self.source_config.topicFilterPattern,
diff --git a/ingestion/src/metadata/ingestion/source/pipeline/pipeline_service.py b/ingestion/src/metadata/ingestion/source/pipeline/pipeline_service.py
index 234a7a5d1e9..5e5decd46df 100644
--- a/ingestion/src/metadata/ingestion/source/pipeline/pipeline_service.py
+++ b/ingestion/src/metadata/ingestion/source/pipeline/pipeline_service.py
@@ -211,7 +211,7 @@ class PipelineServiceSource(TopologyRunnerMixin, Source, ABC):
                 self.metadata,
                 entity_type=Pipeline,
                 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(
                 self.source_config.pipelineFilterPattern,