Commit b1e1ba8a authored by Jeromy's avatar Jeromy

cleanup from CR

parent 74915efd
...@@ -331,14 +331,10 @@ func (ds *dagService) GetDAG(ctx context.Context, root *Node) <-chan *Node { ...@@ -331,14 +331,10 @@ func (ds *dagService) GetDAG(ctx context.Context, root *Node) <-chan *Node {
nodes[i] = nd nodes[i] = nd
} }
if next == is[0] {
sig <- nd
next++
for ; next < len(nodes) && nodes[next] != nil; next++ { for ; next < len(nodes) && nodes[next] != nil; next++ {
sig <- nodes[next] sig <- nodes[next]
} }
} }
}
if next < len(nodes) { if next < len(nodes) {
// TODO: bubble errors back up. // TODO: bubble errors back up.
log.Errorf("Did not receive correct number of nodes!") log.Errorf("Did not receive correct number of nodes!")
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment