Skip to content

Commit

Permalink
fix test
Browse files Browse the repository at this point in the history
  • Loading branch information
EasterTheBunny committed May 22, 2024
1 parent 6aecbdd commit a8edcf2
Showing 1 changed file with 6 additions and 6 deletions.
12 changes: 6 additions & 6 deletions core/services/pipeline/graph_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -171,27 +171,27 @@ func TestGraph_TasksInDependencyOrder(t *testing.T) {
"ds1_multiply",
[]pipeline.TaskDependency{{PropagateResult: true, InputTask: pipeline.Task(ds1_parse)}},
[]pipeline.Task{answer1},
0)
-1)
ds2_multiply.BaseTask = pipeline.NewBaseTask(
5,
"ds2_multiply",
[]pipeline.TaskDependency{{PropagateResult: true, InputTask: pipeline.Task(ds2_parse)}},
[]pipeline.Task{answer1},
0)
-1)
ds1_parse.BaseTask = pipeline.NewBaseTask(
1,
"ds1_parse",
[]pipeline.TaskDependency{{PropagateResult: true, InputTask: pipeline.Task(ds1)}},
[]pipeline.Task{ds1_multiply},
0)
-1)
ds2_parse.BaseTask = pipeline.NewBaseTask(
4,
"ds2_parse",
[]pipeline.TaskDependency{{PropagateResult: true, InputTask: pipeline.Task(ds2)}},
[]pipeline.Task{ds2_multiply},
0)
ds1.BaseTask = pipeline.NewBaseTask(0, "ds1", nil, []pipeline.Task{ds1_parse}, 0)
ds2.BaseTask = pipeline.NewBaseTask(3, "ds2", nil, []pipeline.Task{ds2_parse}, 0)
-1)
ds1.BaseTask = pipeline.NewBaseTask(0, "ds1", nil, []pipeline.Task{ds1_parse}, -1)
ds2.BaseTask = pipeline.NewBaseTask(3, "ds2", nil, []pipeline.Task{ds2_parse}, -1)

for i, task := range p.Tasks {
// Make sure inputs appear before the task, and outputs don't
Expand Down

0 comments on commit a8edcf2

Please sign in to comment.