func main() {
	var g dag.AcyclicGraph
	g.Add("a")
	g.Add("b")
	g.Add("c")
	g.Connect(dag.BasicEdge("c", "b"))
	g.Connect(dag.BasicEdge("c", "a"))

	p := NewScheduler(&g)

    // Create a set of topological task deps (like those between packages)
	topoDeps := make(util.Set)
    // Create a set of regular task deps (like those within the same package)
	deps := make(util.Set)

	// Add `build` to the set of topological deps (e.g. `^build`)
    // This translates to: <task> depends on its dependencies' `build` task
	topoDeps.Add("build")

    // Add `prepare` to the set of deps.
    // This translates to: <task> depends on its own `prepare` `task`
	deps.Add("prepare")

    // Add tasks to the scheduler (would be based on some kind of pipeline definition)
	p.AddTask(&Task{
		Name:     "build",
		TopoDeps: topoDeps, // build depends on its deps' build command
		Deps:     deps, // build depends on its own prepare command
		Run: func(taskId string) error {            
			fmt.Println(taskId)
			return nil
		},
	})

	p.AddTask(&Task{
		Name:     "test",
		TopoDeps: topoDeps, // test depends on its deps' build command
		Deps:     deps, // test depends on its own prepare command
		Run: func(taskId string) error {
			fmt.Println(taskId)
			return nil
		},
	})

	p.AddTask(&Task{
		Name: "prepare",
		Run: func(taskId string) error {
			fmt.Println(taskId)
			return nil
		},
	})

    // Execute constructs a new task graph based on current topologic dep graph and execution scope (packages and task names). It then
    // walks the task graph just like before. It will ensure that all transitive tasks are correctly included so that their is no need know the full set of tasks ahead of time
    errs := p.Execute(&SchedulerExecutionOptions{
		Packages:   nil, // optionally restrict packages in scope
		TaskNames:  []string{"test"},  // optionally restrict task's in scope
		Concurreny: 10, // set graph concurrency
		Parallel:   false, // control parallel running (if true, it removes all task graph edges)
	})

	for _, err := range errs {
		log.Fatalf("%v", err)
	}     

	log.Println(strings.TrimSpace(p.TaskGraph.String()))
}