Commit 0014e111 authored by vicotor's avatar vicotor

fix bug

parent 657295ea
...@@ -258,7 +258,7 @@ func (d *Dao) HandleTasks() { ...@@ -258,7 +258,7 @@ func (d *Dao) HandleTasks() {
continue continue
} }
if event.UpdatedAt.Compare(event.CreatedAt) > 0 && (int(event.UpdatedAt.Sub(time.Now()).Seconds()) < d.c.TaskRetryInterval) { if event.UpdatedAt.Compare(event.CreatedAt) > 0 && (int(time.Now().Sub(event.UpdatedAt).Seconds()) < d.c.TaskRetryInterval) {
// skip recently failed tasks. // skip recently failed tasks.
continue continue
} }
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment