Skip to content

Commit 93fa962

Browse files
committed
fix other minor preexisting lint issues
1 parent 942c9e8 commit 93fa962

File tree

2 files changed

+4
-3
lines changed

2 files changed

+4
-3
lines changed

internal/maintenance/job_scheduler_test.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -27,13 +27,13 @@ func TestJobScheduler(t *testing.T) {
2727
notificationsByQueue map[string]int
2828
}
2929

30-
setup := func(t *testing.T, ex riverdriver.Executor) (*JobScheduler, *testBundle) {
30+
setup := func(t *testing.T, exec riverdriver.Executor) (*JobScheduler, *testBundle) {
3131
t.Helper()
3232

3333
archetype := riverinternaltest.BaseServiceArchetype(t)
3434

3535
bundle := &testBundle{
36-
exec: ex,
36+
exec: exec,
3737
notificationsByQueue: make(map[string]int),
3838
}
3939

internal/maintenance/periodic_job_enqueuer_test.go

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -2,6 +2,7 @@ package maintenance
22

33
import (
44
"context"
5+
"errors"
56
"fmt"
67
"sync"
78
"testing"
@@ -568,7 +569,7 @@ func TestPeriodicJobEnqueuer(t *testing.T) {
568569
})
569570

570571
svc.Config.NotifyInsert = func(ctx context.Context, execTx riverdriver.ExecutorTx, queues []string) error {
571-
return fmt.Errorf("test error")
572+
return errors.New("test error")
572573
}
573574

574575
startService(t, svc)

0 commit comments

Comments
 (0)