in python/old_code/protobuf/planwriter.py [0:0]
def set_dependencies(self):
for source in self.sources:
if 'end' in self.boundaries[source.id]:
op_successors = []
for op_id in self.boundaries[source.id]['end']:
op_successors.append(str(self.operator_references[str(op_id)].id))
source.successors.extend(op_successors)
for sink in self.sinks:
if 'start' in self.boundaries[sink.id]:
op_predecessors = []
for op_id in self.boundaries[sink.id]['start']:
op_predecessors.append(str(self.operator_references[str(op_id)].id))
sink.predecessors.extend(op_predecessors)
for op in self.operators:
if 'start' in self.boundaries[op.id]:
op_predecessors = []
for op_id in self.boundaries[op.id]['start']:
op_predecessors.append(str(self.operator_references[str(op_id)].id))
op.predecessors.extend(op_predecessors)
if 'end' in self.boundaries[op.id]:
op_successors = []
for op_id in self.boundaries[op.id]['end']:
op_successors.append(str(self.operator_references[str(op_id)].id))
op.successors.extend(op_successors)