98f7bac81b00256bc31e66aab2d7752bc320e67c,odps/df/backends/optimize/utils.py,,copy_sequence,#Any#Any#Any#,44

Before Change

    if dag:
        dag.add_node(copied)
    is_copied = set()
    for path in sequence.all_path(collection, strict=True):
        curr = copied
        for seq in path[1:-1]:
            if id(seq) in is_copied:
                continue
            is_copied.add(id(seq))
            copied_seq = seq.copy()
            curr.substitute(seq, copied_seq, dag=dag)
            curr = copied_seq

    return copied

After Change

        if n is collection:
            continue

        parents = [p for p in dag.successors(n) if p._node_id in traversed]
        for parent in parents:
            copy(parent).substitute(n, copy(n), dag=dag)

    return copies[sequence._node_id]

Instances