@property<EOL><INDENT>def dag(self) -> Tuple[Dict, Dict]:<DEDENT>
from pipelines import dags<EOL>operations = self.operations.all().prefetch_related('<STR_LIT>')<EOL>def get_downstream(op):<EOL><INDENT>return op.downstream_operations.values_list('<STR_LIT:id>', flat=True)<EOL><DEDENT>return dags.get_dag(operations, get_downstream)<EOL>
Construct the DAG of this pipeline based on the its operations and their downstream.