me/neoq
1
0
Fork 0
mirror of https://github.com/acaloiaro/neoq synced 2026-07-21 18:29:08 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

Use time.Until instead of t.Sub(time.Now())

Browse source
This commit is contained in:
Adriano Caloiaro 2023-02-15 10:59:59 -08:00
parent fc011c9c84
commit 84826b5f0a
No known key found for this signature in database
GPG key ID: 890FFDB11860FE1C
1 changed files with 1 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
neoq.go
View file

@ -653,7 +653,7 @@ func (w pgWorker) updateJob(ctx context.Context, jobErr error) (err error) {
_, err = tx.Exec(ctx, qstr, time.Now(), errMsg, status, job.ID)
}
if err == nil && runAfter.Sub(time.Now()) > 0 {
if err == nil && time.Until(runAfter) > 0 {
w.mu.Lock()
w.futureJobs[job.ID] = runAfter
w.mu.Unlock()