1 Commits

Author SHA1 Message Date
6403f26cd7 with capture 2022-10-30 15:46:52 +01:00

10
byg.go
View File

@@ -2,6 +2,7 @@ package byg
import (
"context"
"log"
"sync"
"golang.org/x/sync/errgroup"
@@ -52,12 +53,15 @@ func (bb *Builder) Execute(ctx context.Context) error {
defer bb.addmu.Unlock()
for _, step := range bb.steps {
log.Printf("executing step: %s", step.name)
errgroup, _ := errgroup.WithContext(ctx)
for _, task := range step.tasks {
errgroup.Go(func() error {
return task(Context{})
})
func(task StepExecuteFunc) {
errgroup.Go(func() error {
return task(Context{})
})
}(task)
}
if err := errgroup.Wait(); err != nil {