d82cbd1a1ffd9122ee169ef34973b3def10b0c2a,polyaxon_schemas/polyflow/pipeline.py,PipelineConfig,get_independent_ops,#PipelineConfig#Any#,165

Before Change

    def get_independent_ops(self, dag=None):
        Get a list of all node in the graph with no dependencies.
        dag = dag or self.dag
        ops = set(six.iterkeys(dag))
        dependent_nodes = {
            op_downstream
            for op in six.itervalues(dag)
            for op_downstream in op.downstream
        }
        return ops - dependent_nodes

    def get_orphan_ops(self, dag=None):
        Get orphan ops for given dag.
        dag = dag or self.dag

After Change

    def get_independent_ops(self, dag=None):
        Get a list of all node in the graph with no dependencies.
        return dags.get_independent_ops(self.dag or dag)

    def get_orphan_ops(self, dag=None):
        Get orphan ops for given dag.
        return dags.get_orphan_ops(dag or self.dag)

Instances