SQuiz/amocrm
2
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

fix panic reset tiker

Browse Source
This commit is contained in:
Pavel 2024-05-20 12:26:21 +03:00
parent 8290f5c880
commit 337fa4607a
1 changed files with 3 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
internal/workers/data_updater/data_updater.go
View File

@ -36,6 +36,9 @@ func (wc *DataUpdater) Start(ctx context.Context) {
case <-ticker.C: case <-ticker.C:
wc.processTasks(ctx) wc.processTasks(ctx)
nextStart = calculateTime() nextStart = calculateTime()
if nextStart <= 0 {
nextStart = 86400
}
ticker.Reset(time.Second * time.Duration(nextStart)) ticker.Reset(time.Second * time.Duration(nextStart))
case <-ctx.Done(): case <-ctx.Done():
return return