docs(ingest) Add MetadataChangeProposalWrapper import to example code (…

…datahub-project#8175) Co-authored-by: Indy Prentice <[email protected]>
jinlintt · Jun 7, 2023 · b20561a · b20561a
1 parent 593fec5
commit b20561a
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/docs/modeling/metadata-model.md b/docs/modeling/metadata-model.md
@@ -478,6 +478,7 @@ from datahub.metadata.schema_classes import (
  DatasetUsageStatisticsClass,
 )
 from datahub.emitter.kafka_emitter import DatahubKafkaEmitter
+from datahub.emitter.mcp import MetadataChangeProposalWrapper
 from datahub.emitter.rest_emitter import DatahubRestEmitter
 
 usageStats = DatasetUsageStatisticsClass(
@@ -500,8 +501,9 @@ mcpw = MetadataChangeProposalWrapper(
  aspect=usageStats,
 )
 
-# Instantiate appropriate emitter (kafk_emitter/rest_emitter)
-my_emitter = DatahubKafkaEmitter("""<config>""")
+# Instantiate appropriate emitter (kafka_emitter/rest_emitter)
+# my_emitter = DatahubKafkaEmitter("""<config>""")
+my_emitter = DatahubRestEmitter("https://localhost:8080")
 my_emitter.emit(mcpw)
 ```