hi,team. i try the lineage_job_dataflow_new_api.py...
# ingestion
c
hi,team. i try the lineage_job_dataflow_new_api.py.and the data is successfully warehoused.
Copy code
jobFlow = DataFlow(cluster="prod", orchestrator="airflow", id="flow_new_api")
jobFlow.emit(emitter)

dataJob = DataJob(flow_urn=jobFlow.urn, id="flow_new_api_job1")
dataJob.emit(emitter)
But in the UI, I found that they were not related,How to troubleshoot here?
h
Hey @cuddly-arm-8412 this is not supposed to happen! I tried the shared snippet and it worked for me with acryl-datahub, version 0.8.44.3 as expected. Did the script execute successfully in your case ? Can you try re-executing the script and checking logs on datahub-gms container if there are any errors ?