Method add_op

python/graphscope/framework/dag.py:54–61

(self, op)

        return op.key in self._ops_by_key

    def add_op(self, op):
        if not isinstance(op, Operation):
            raise TypeError("op must be an Operation: {0}".format(op))
        if not op.evaluated and op.key in self._ops_by_key:
            raise ValueError("op named {0} already exist in dag".format(op.key))
        self._ops_by_key[op.key] = op
        self._ops_seq_by_key[op.key] = self._seq
        self._seq += 1

    def as_dag_def(self):
        """Return :class:`Dag` as a :class:`DagDef` proto buffer."""