fix tests

This commit is contained in:
John Roesler 2025-08-27 15:04:09 -05:00
parent a012e88be9
commit 383933c971
No known key found for this signature in database
GPG Key ID: 3AA260B9FCA0A6E1
1 changed files with 7 additions and 7 deletions

View File

@ -1506,7 +1506,7 @@ func TestScheduler_OneTimeJob_DoesNotCleanupNext(t *testing.T) {
clock.Advance(oneSecondAfterNextRun.Sub(schedulerStartTime))
require.Eventually(t, func() bool {
return assert.Equal(t, uint32(1), runs.Load())
return uint32(1) == runs.Load()
}, 3*time.Second, 100*time.Millisecond)
// last was run
@ -2458,7 +2458,7 @@ func TestScheduler_AtTimesJob(t *testing.T) {
// advance and eventually run
clock.Advance(2 * time.Millisecond)
require.Eventually(t, func() bool {
return assert.Equal(t, uint32(1), runs.Load())
return uint32(1) == runs.Load()
}, 3*time.Second, 100*time.Millisecond)
// last was run
@ -2493,7 +2493,7 @@ func TestScheduler_AtTimesJob(t *testing.T) {
// advance and eventually run
clock.Advance(2 * time.Millisecond)
require.Eventually(t, func() bool {
return assert.Equal(t, uint32(1), runs.Load())
return uint32(1) == runs.Load()
}, 3*time.Second, 100*time.Millisecond)
// last was run
@ -2524,7 +2524,7 @@ func TestScheduler_AtTimesJob(t *testing.T) {
// advance and eventually run
clock.Advance(2 * time.Millisecond)
require.Eventually(t, func() bool {
return assert.Equal(t, uint32(1), runs.Load())
return uint32(1) == runs.Load()
}, 3*time.Second, 100*time.Millisecond)
// last was run
@ -2541,7 +2541,7 @@ func TestScheduler_AtTimesJob(t *testing.T) {
// advance and eventually run
clock.Advance(2 * time.Millisecond)
require.Eventually(t, func() bool {
return assert.Equal(t, uint32(2), runs.Load())
return uint32(2) == runs.Load()
}, 3*time.Second, 100*time.Millisecond)
// last was run
@ -2577,7 +2577,7 @@ func TestScheduler_AtTimesJob(t *testing.T) {
// advance and eventually run
clock.Advance(2 * time.Millisecond)
require.Eventually(t, func() bool {
return assert.Equal(t, uint32(1), runs.Load())
return uint32(1) == runs.Load()
}, 3*time.Second, 100*time.Millisecond)
// last was run
@ -2594,7 +2594,7 @@ func TestScheduler_AtTimesJob(t *testing.T) {
// advance and eventually run
clock.Advance(2 * time.Millisecond)
require.Eventually(t, func() bool {
return assert.Equal(t, uint32(2), runs.Load())
return uint32(2) == runs.Load()
}, 3*time.Second, 100*time.Millisecond)
// last was run