Skip to content

Commit

Permalink
dag: fix typo: TaskDependensOn -> TaskDependsOn
Browse files Browse the repository at this point in the history
  • Loading branch information
@DavidGamba
DavidGamba committed Oct 2, 2024
1 parent e2fd865 commit 907c568
Show file tree
Hide file tree
Showing 3 changed files with 55 additions and 55 deletions.
4 changes: 2 additions & 2 deletions dag/dag.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -339,8 +339,8 @@ func (g *Graph) retrieveOrAddVertex(t *Task) (*Vertex, error) {
return vertex, nil
}

// TaskDependensOn - Allows adding tasks to the graph and defining their edges.
func (g *Graph) TaskDependensOn(t *Task, tDependencies ...*Task) {
// TaskDependsOn - Allows adding tasks to the graph and defining their edges.
func (g *Graph) TaskDependsOn(t *Task, tDependencies ...*Task) {
vertex, err := g.retrieveOrAddVertex(t)
if err != nil {
g.errs.Errors = append(g.errs.Errors, err)
Expand Down
100 changes: 50 additions & 50 deletions dag/dag_test.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -57,13 +57,13 @@ func TestDag(t *testing.T) {
tm.Add("t8", generateFn(8))

g := NewGraph("test graph")
g.TaskDependensOn(tm.Get("t1"), tm.Get("t2"), tm.Get("t3"))
g.TaskDependensOn(tm.Get("t2"), tm.Get("t4"))
g.TaskDependensOn(tm.Get("t3"), tm.Get("t4"))
g.TaskDependensOn(tm.Get("t4"), tm.Get("t5"))
g.TaskDependensOn(tm.Get("t6"), tm.Get("t2"))
g.TaskDependensOn(tm.Get("t6"), tm.Get("t8"))
g.TaskDependensOn(tm.Get("t7"), tm.Get("t5"))
g.TaskDependsOn(tm.Get("t1"), tm.Get("t2"), tm.Get("t3"))
g.TaskDependsOn(tm.Get("t2"), tm.Get("t4"))
g.TaskDependsOn(tm.Get("t3"), tm.Get("t4"))
g.TaskDependsOn(tm.Get("t4"), tm.Get("t5"))
g.TaskDependsOn(tm.Get("t6"), tm.Get("t2"))
g.TaskDependsOn(tm.Get("t6"), tm.Get("t8"))
g.TaskDependsOn(tm.Get("t7"), tm.Get("t5"))

// Validate before running
err = g.Validate(tm)
Expand Down Expand Up @@ -191,12 +191,12 @@ func TestRunErrorCollection(t *testing.T) {
g.AddTask(NewTask("", generateFn(123))) // ErrorTaskID
g.AddTask(NewTask("123", nil)) // ErrorTaskFn

g.TaskDependensOn(g.Task("t2"), g.Task("t1"))
g.TaskDependensOn(g.Task("t3"), g.Task("t2"))
g.TaskDependensOn(g.Task("t3"), g.Task("t0")) // ErrorTaskNotFound, ErrorTaskFn
g.TaskDependensOn(g.Task("t0"), g.Task("t3")) // ErrorTaskNotFound, ErrorTaskFn
g.TaskDependensOn(g.Task("t2"), g.Task("t1")) // ErrorTaskDependencyDuplicate
g.TaskDependensOn(g.Task("t2"), nil) // ErrorTaskNil
g.TaskDependsOn(g.Task("t2"), g.Task("t1"))
g.TaskDependsOn(g.Task("t3"), g.Task("t2"))
g.TaskDependsOn(g.Task("t3"), g.Task("t0")) // ErrorTaskNotFound, ErrorTaskFn
g.TaskDependsOn(g.Task("t0"), g.Task("t3")) // ErrorTaskNotFound, ErrorTaskFn
g.TaskDependsOn(g.Task("t2"), g.Task("t1")) // ErrorTaskDependencyDuplicate
g.TaskDependsOn(g.Task("t2"), nil) // ErrorTaskNil

g.TaskRetries(g.Task("t99"), 3) // ErrorTaskNotFound, ErrorTaskFn

Expand Down Expand Up @@ -285,8 +285,8 @@ func TestCycle(t *testing.T) {
g.AddTask(NewTask("t1", generateFn(1)))
g.AddTask(NewTask("t2", generateFn(2)))

g.TaskDependensOn(g.Task("t1"), g.Task("t2"))
g.TaskDependensOn(g.Task("t2"), g.Task("t1"))
g.TaskDependsOn(g.Task("t1"), g.Task("t2"))
g.TaskDependsOn(g.Task("t2"), g.Task("t1"))
_, err := g.DepthFirstSort()
if err == nil || !errors.Is(err, ErrorGraphHasCycle) {
t.Errorf("Wrong error: %s\n", err)
Expand Down Expand Up @@ -329,13 +329,13 @@ func TestDagTaskError(t *testing.T) {
g.AddTask(NewTask("t7", generateFn(7)))
g.AddTask(NewTask("t8", generateFn(8)))

g.TaskDependensOn(g.Task("t1"), g.Task("t2"), g.Task("t3"))
g.TaskDependensOn(g.Task("t2"), g.Task("t4"))
g.TaskDependensOn(g.Task("t3"), g.Task("t4"))
g.TaskDependensOn(g.Task("t4"), g.Task("t5"))
g.TaskDependensOn(g.Task("t6"), g.Task("t2"))
g.TaskDependensOn(g.Task("t6"), g.Task("t8"))
g.TaskDependensOn(g.Task("t7"), g.Task("t5"))
g.TaskDependsOn(g.Task("t1"), g.Task("t2"), g.Task("t3"))
g.TaskDependsOn(g.Task("t2"), g.Task("t4"))
g.TaskDependsOn(g.Task("t3"), g.Task("t4"))
g.TaskDependsOn(g.Task("t4"), g.Task("t5"))
g.TaskDependsOn(g.Task("t6"), g.Task("t2"))
g.TaskDependsOn(g.Task("t6"), g.Task("t8"))
g.TaskDependsOn(g.Task("t7"), g.Task("t5"))

err = g.Run(context.Background(), nil, nil)
var errs *Errors
Expand Down Expand Up @@ -411,13 +411,13 @@ func TestDagTaskErrorRetry(t *testing.T) {
g.AddTask(NewTask("t7", generateFn(7)))
g.AddTask(NewTask("t8", generateFn(8)))

g.TaskDependensOn(g.Task("t1"), g.Task("t2"), g.Task("t3"))
g.TaskDependensOn(g.Task("t2"), g.Task("t4"))
g.TaskDependensOn(g.Task("t3"), g.Task("t4"))
g.TaskDependensOn(g.Task("t4"), g.Task("t5"))
g.TaskDependensOn(g.Task("t6"), g.Task("t2"))
g.TaskDependensOn(g.Task("t6"), g.Task("t8"))
g.TaskDependensOn(g.Task("t7"), g.Task("t5"))
g.TaskDependsOn(g.Task("t1"), g.Task("t2"), g.Task("t3"))
g.TaskDependsOn(g.Task("t2"), g.Task("t4"))
g.TaskDependsOn(g.Task("t3"), g.Task("t4"))
g.TaskDependsOn(g.Task("t4"), g.Task("t5"))
g.TaskDependsOn(g.Task("t6"), g.Task("t2"))
g.TaskDependsOn(g.Task("t6"), g.Task("t8"))
g.TaskDependsOn(g.Task("t7"), g.Task("t5"))

err := g.Run(context.Background(), nil, nil)
if err != nil {
Expand Down Expand Up @@ -510,13 +510,13 @@ func TestDagContexDone(t *testing.T) {
g.AddTask(NewTask("t7", generateFn(7)))
g.AddTask(NewTask("t8", generateFn(8)))

g.TaskDependensOn(g.Task("t1"), g.Task("t2"), g.Task("t3"))
g.TaskDependensOn(g.Task("t2"), g.Task("t4"))
g.TaskDependensOn(g.Task("t3"), g.Task("t4"))
g.TaskDependensOn(g.Task("t4"), g.Task("t5"))
g.TaskDependensOn(g.Task("t6"), g.Task("t2"))
g.TaskDependensOn(g.Task("t6"), g.Task("t8"))
g.TaskDependensOn(g.Task("t7"), g.Task("t5"))
g.TaskDependsOn(g.Task("t1"), g.Task("t2"), g.Task("t3"))
g.TaskDependsOn(g.Task("t2"), g.Task("t4"))
g.TaskDependsOn(g.Task("t3"), g.Task("t4"))
g.TaskDependsOn(g.Task("t4"), g.Task("t5"))
g.TaskDependsOn(g.Task("t6"), g.Task("t2"))
g.TaskDependsOn(g.Task("t6"), g.Task("t8"))
g.TaskDependsOn(g.Task("t7"), g.Task("t5"))

err = g.Run(ctx, nil, nil)
var errs *Errors
Expand Down Expand Up @@ -588,13 +588,13 @@ func TestDagTaskSkipParents(t *testing.T) {
g.AddTask(NewTask("t7", generateFn(7)))
g.AddTask(NewTask("t8", generateFn(8)))

g.TaskDependensOn(g.Task("t1"), g.Task("t2"), g.Task("t3"))
g.TaskDependensOn(g.Task("t2"), g.Task("t4"))
g.TaskDependensOn(g.Task("t3"), g.Task("t4"))
g.TaskDependensOn(g.Task("t4"), g.Task("t5"))
g.TaskDependensOn(g.Task("t6"), g.Task("t2"))
g.TaskDependensOn(g.Task("t6"), g.Task("t8"))
g.TaskDependensOn(g.Task("t7"), g.Task("t5"))
g.TaskDependsOn(g.Task("t1"), g.Task("t2"), g.Task("t3"))
g.TaskDependsOn(g.Task("t2"), g.Task("t4"))
g.TaskDependsOn(g.Task("t3"), g.Task("t4"))
g.TaskDependsOn(g.Task("t4"), g.Task("t5"))
g.TaskDependsOn(g.Task("t6"), g.Task("t2"))
g.TaskDependsOn(g.Task("t6"), g.Task("t8"))
g.TaskDependsOn(g.Task("t7"), g.Task("t5"))

err = g.Run(context.Background(), nil, nil)
if err != nil {
Expand Down Expand Up @@ -645,13 +645,13 @@ func TestDagSerial(t *testing.T) {
tm.Add("t8", generateFn(8))

g := NewGraph("test graph").SetSerial()
g.TaskDependensOn(tm.Get("t1"), tm.Get("t2"), tm.Get("t3"))
g.TaskDependensOn(tm.Get("t2"), tm.Get("t4"))
g.TaskDependensOn(tm.Get("t3"), tm.Get("t4"))
g.TaskDependensOn(tm.Get("t4"), tm.Get("t5"))
g.TaskDependensOn(tm.Get("t6"), tm.Get("t2"))
g.TaskDependensOn(tm.Get("t6"), tm.Get("t8"))
g.TaskDependensOn(tm.Get("t7"), tm.Get("t5"))
g.TaskDependsOn(tm.Get("t1"), tm.Get("t2"), tm.Get("t3"))
g.TaskDependsOn(tm.Get("t2"), tm.Get("t4"))
g.TaskDependsOn(tm.Get("t3"), tm.Get("t4"))
g.TaskDependsOn(tm.Get("t4"), tm.Get("t5"))
g.TaskDependsOn(tm.Get("t6"), tm.Get("t2"))
g.TaskDependsOn(tm.Get("t6"), tm.Get("t8"))
g.TaskDependsOn(tm.Get("t7"), tm.Get("t5"))

// Validate before running
err = g.Validate(tm)
Expand Down
6 changes: 3 additions & 3 deletions examples/dag/main.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -66,7 +66,7 @@ func program(args []string) int {
func Build(ctx context.Context, opt *getoptions.GetOpt, args []string) error {
Logger.Printf("Running build command")
g := dag.NewGraph("build graph")
g.TaskDependensOn(TM.Get("bt3"), TM.Get("bt1"), TM.Get("bt2"))
g.TaskDependsOn(TM.Get("bt3"), TM.Get("bt1"), TM.Get("bt2"))
err := g.Validate(TM)
if err != nil {
return err
Expand All @@ -81,8 +81,8 @@ func Build(ctx context.Context, opt *getoptions.GetOpt, args []string) error {
func Clean(ctx context.Context, opt *getoptions.GetOpt, args []string) error {
Logger.Printf("Running clean command")
g := dag.NewGraph("clean graph")
g.TaskDependensOn(TM.Get("ct1"), TM.Get("ct3"))
g.TaskDependensOn(TM.Get("ct2"), TM.Get("ct3"))
g.TaskDependsOn(TM.Get("ct1"), TM.Get("ct3"))
g.TaskDependsOn(TM.Get("ct2"), TM.Get("ct3"))
err := g.Validate(TM)
if err != nil {
return err
Expand Down

0 comments on commit 907c568

Please sign in to comment.