pkg/asynq
2
0
Fork 0
mirror of https://github.com/hibiken/asynq.git synced 2026-01-29 17:24:24 +00:00
Code Issues Projects Releases Wiki Activity

Update recoverer to recover tasks on server startup

Browse Source
This commit is contained in:
Ken Hibino
2021-07-04 06:21:56 -07:00
parent ff6768f9bb
commit f532c95394
1 changed files with 1 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
recoverer.go
View File

@@ -57,6 +57,7 @@ func (r *recoverer) start(wg *sync.WaitGroup) {
wg.Add(1) wg.Add(1)
go func() { go func() {
defer wg.Done() defer wg.Done()
r.recover()
timer := time.NewTimer(r.interval) timer := time.NewTimer(r.interval)
for { for {
select { select {