make_datahub_lineage_op
(upstream_urns
:List
[str
], downstream_urn
:str
, task_id
:str
=None
, datahub_conn_id
:str
='datahub_rest_default'
, env
:str
='DEV'
, source_type
:str
='bigquery'
)
Aims to simplify the creation of a Datahub lineage by returning an initialized DatahubEmitterOperator
.