bright-cpu-56427
06/13/2022, 9:48 AMemit_lineage_task = DatahubEmitterOperator(
task_id=f"emit_lineage_{table}",
datahub_conn_id="datahub_rest_default",
mces=[
builder.make_lineage_mce(
upstream_urns=upstreams,
downstream_urn=builder.make_dataset_urn(downstream[0], downstream[1]),
)
],
)
emit_lineage_task.execute(kwargs)
log file
[2022-06-13 09:27:43,912] {_lineage_core.py:67} INFO - Emitted from Lineage:
DataFlow(urn=<datahub.utilities.urns.data_flow_urn.DataFlowUrn object at 0x7f9bcf23eee0>, ... url='<http://localhost:8080/tree?dag_id=dag>', ...)
dazzling-judge-80093
06/13/2022, 10:46 AMbase_url
config parameter in your airflow config:
https://airflow.apache.org/docs/apache-airflow/stable/configurations-ref.html#base-url