We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 925626b commit c35b89fCopy full SHA for c35b89f
manager.go
@@ -2,6 +2,7 @@ package runnable
2
3
import (
4
"context"
5
+ "errors"
6
"fmt"
7
"strings"
8
"time"
@@ -71,7 +72,7 @@ func (m *manager) Run(ctx context.Context) error {
71
72
case c := <-completedChan:
73
completed.insert(c)
74
- if c.err == nil {
75
+ if c.err == nil || errors.Is(c.err, context.Canceled) {
76
m.log("%s stopped", c.name())
77
} else {
78
m.log("%s stopped with error: %+v", c.name(), c.err)
0 commit comments