We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent debc92f commit b1e41f5Copy full SHA for b1e41f5
pkg/utils/sleeper_task.go
@@ -2,8 +2,6 @@ package utils
2
3
import (
4
"context"
5
- "fmt"
6
- "time"
7
8
"github.com/smartcontractkit/chainlink-common/pkg/services"
9
)
@@ -70,11 +68,7 @@ func NewSleeperTaskCtx(w WorkerCtx) *SleeperTask {
70
68
func (s *SleeperTask) Stop() error {
71
69
return s.StopOnce("SleeperTask-"+s.worker.Name(), func() error {
72
close(s.chStop)
73
- select {
74
- case <-s.chDone:
75
- case <-time.After(15 * time.Second):
76
- return fmt.Errorf("SleeperTask-%s took too long to stop", s.worker.Name())
77
- }
+ <-s.chDone
78
return nil
79
})
80
}
0 commit comments