Extend timeouts in timed_workers_test
This commit is contained in:
@@ -89,7 +89,7 @@ func TestCancel(t *testing.T) {
|
|||||||
return nil
|
return nil
|
||||||
})
|
})
|
||||||
now := time.Now()
|
now := time.Now()
|
||||||
then := now.Add(100 * time.Millisecond)
|
then := now.Add(time.Second)
|
||||||
queue.AddWork(NewWorkArgs("1", "1"), now, then)
|
queue.AddWork(NewWorkArgs("1", "1"), now, then)
|
||||||
queue.AddWork(NewWorkArgs("2", "2"), now, then)
|
queue.AddWork(NewWorkArgs("2", "2"), now, then)
|
||||||
queue.AddWork(NewWorkArgs("3", "3"), now, then)
|
queue.AddWork(NewWorkArgs("3", "3"), now, then)
|
||||||
@@ -119,7 +119,7 @@ func TestCancelAndReadd(t *testing.T) {
|
|||||||
return nil
|
return nil
|
||||||
})
|
})
|
||||||
now := time.Now()
|
now := time.Now()
|
||||||
then := now.Add(100 * time.Millisecond)
|
then := now.Add(time.Second)
|
||||||
queue.AddWork(NewWorkArgs("1", "1"), now, then)
|
queue.AddWork(NewWorkArgs("1", "1"), now, then)
|
||||||
queue.AddWork(NewWorkArgs("2", "2"), now, then)
|
queue.AddWork(NewWorkArgs("2", "2"), now, then)
|
||||||
queue.AddWork(NewWorkArgs("3", "3"), now, then)
|
queue.AddWork(NewWorkArgs("3", "3"), now, then)
|
||||||
|
Reference in New Issue
Block a user