Hey guys, i'm playing around with lineage ingestion using the python DatahubKafkaEmitter and noticed that when i insert two separate

upstreamLineage

events that it replaces my previously set lineages. Anyone know of a way to make this additive instead of a full replace? Thanks!

Use the API to get the data, edit it and then emit it

Ah, i would have thought that we could emit a seperate event for adding a lineage and removing a lineage. Thanks