best-receptionist-79324
07/28/2022, 4:34 PMupstream_table_1 = UpstreamClass(
dataset=builder.make_dataset_urn("DEPENDENCY_MAP", "upstream_table_4", "DEV"),
type=DatasetLineageTypeClass.TRANSFORMED,
)
upstream_tables: List[UpstreamClass] = [upstream_table_1]
upstream_table_2 = UpstreamClass(
dataset=builder.make_dataset_urn("DEPENDENCY_MAP", "upstream_table_3", "DEV"),
type=DatasetLineageTypeClass.TRANSFORMED,
)
upstream_tables.append(upstream_table_2)
# Construct a lineage object.
upstream_lineage = UpstreamLineage(upstreams=upstream_tables)
# Construct a MetadataChangeProposalWrapper object.
lineage_mcp = MetadataChangeProposalWrapper(
entityType="dataset",
changeType=ChangeTypeClass.UPSERT,
entityUrn=builder.make_dataset_urn("DEPENDENCY_MAP", "downstream", "DEV"),
aspectName="upstreamLineage",
aspect=upstream_lineage,
)
# Emit metadata
emitter.emit_mcp(lineage_mcp)
Thanks!
--Robcareful-pilot-86309
07/29/2022, 5:10 AMmake_dataset_urn_with_platform_instance
instead of plain make_dataset_urn
best-receptionist-79324
07/29/2022, 7:31 PM