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