Method Run

dag/dag.go:99–110

Run runs the dag. Vertexes with no dependency will be scheduled concurrently while the inked vertexes will be scheduled sequentially. The Scheduler optimizes the execution path so that the overall dag execution time is minimized. If a vertex returns an error or if the dag context is canceled, the s

(ctx context.Context)

// dag caller) is to store the results in context with the help of package
// ctxmeta. See example.
func (d *DAG) Run(ctx context.Context) error {
	errGroup, ctx := errgroup.WithContext(ctx)
	for _, v := range d.vertexes {
		v := v
		if len(v.parents) == 0 {
			errGroup.Go(func() error {
				return v.execute(ctx)
			})
		}
	}
	return errGroup.Wait()
}

func (d *DAG) fmtEdges(edges []int) interface{} {
	var s []string