Skip to content

Commit

Permalink
task: fix concurrent write
Browse files Browse the repository at this point in the history
  • Loading branch information
arm64v8a authored Sep 30, 2023
1 parent ce9dfad commit 4cdb4b7
Showing 1 changed file with 2 additions and 0 deletions.
2 changes: 2 additions & 0 deletions common/task/task.go
Original file line number Diff line number Diff line change
Expand Up @@ -88,9 +88,11 @@ func (g *Group) RunContextList(contextList []context.Context) error {

selectedContext, upstreamErr := common.SelectContext(append([]context.Context{taskCancelContext}, contextList...))
if selectedContext != 0 {
errorAccess.Lock()
returnError = E.Append(returnError, upstreamErr, func(err error) error {
return E.Cause(err, "upstream")
})
errorAccess.Unlock()
}

if g.cleanup != nil {
Expand Down

0 comments on commit 4cdb4b7

Please sign in to comment.