(op dag.Op)
| 243 | } |
| 244 | |
| 245 | func parallelPaths(op dag.Op) ([]dag.Seq, bool) { |
| 246 | if s, ok := op.(*dag.ScatterOp); ok { |
| 247 | return s.Paths, true |
| 248 | } |
| 249 | if f, ok := op.(*dag.ForkOp); ok { |
| 250 | return f.Paths, true |
| 251 | } |
| 252 | return nil, false |
| 253 | } |
| 254 | |
| 255 | // concurrentPath returns the largest path within seq from front to end that can |
| 256 | // be parallelized and run concurrently while preserving its semantics where |