tests.system.openlineage.example_openlineage_edge_labels_dag¶
DAG with edge labels on task dependencies.
- It checks:
edge labels appear in AirflowJobFacet.tasks[task_id].downstream_task_edges
labeled edges are serialized as {target_id: {“label”: “…”}}
unlabeled edges are serialized as {target_id: {}} (no label key)
multiple labeled edges from a single task are all captured
a task with mixed labeled and unlabeled outgoing edges captures both correctly
a task with no labels at all serializes all its edges as {}