hey everyone! 👋 In our airflow instance we run subdags within one main dag in order to manage dependencies between workflows. We’re noticing that this results in a broken lineage between parent dag, and the sub-dag. Has anyone noticed this before and found a work around?
h
high-hospital-85984
09/24/2021, 3:34 AM
Good catch. I think currently there is an assumption in the definition of the DataFlow/Pipeline class that they dont have any upstream/downstream lineage property on their own, but only contains DataJobs /Tasks.
a
adamant-pharmacist-61996
09/24/2021, 3:57 AM
it seems that way. In datahub terms I think we’ve done the equivalent of connecting pipelines together. I’d guess the underlying graph structure would need to be extended to account for this type of hierarchy. Something like Pipeline -> executes -> Pipeline