kjuulh/byg
1
0
Fork 0
Code Issues 1 Pull Requests 1 Packages Projects Releases Wiki Activity

with capture

Browse Source
This commit is contained in:
Kasper Juul Hermansen 2022-10-30 15:46:52 +01:00
parent 81bf4841b8
commit 6403f26cd7
Signed by: kjuulh
GPG Key ID: 0F95C140730F2F23
1 changed files with 7 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
byg.go
View File

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