Skip to content

Commit

Permalink
update lint issues
Browse files Browse the repository at this point in the history
  • Loading branch information
JohnRoesler committed Jan 30, 2024
1 parent 978d57f commit 833690e
Show file tree
Hide file tree
Showing 2 changed files with 3 additions and 4 deletions.
4 changes: 2 additions & 2 deletions executor.go
Original file line number Diff line number Diff line change
Expand Up @@ -19,7 +19,7 @@ type executor struct {
jobOutRequest chan jobOutRequest
stopTimeout time.Duration
done chan error
singletonRunners sync.Map //map[uuid.UUID]singletonRunner
singletonRunners *sync.Map // map[uuid.UUID]singletonRunner
limitMode *limitModeConfig
elector Elector
locker Locker
Expand Down Expand Up @@ -67,7 +67,7 @@ func (e *executor) start() {
limitModeJobsWg := &waitGroupWithMutex{}

// create a fresh map for tracking singleton runners
e.singletonRunners = sync.Map{}
e.singletonRunners = &sync.Map{}

// start the for leap that is the executor
// selecting on channels for work to do
Expand Down
3 changes: 1 addition & 2 deletions scheduler.go
Original file line number Diff line number Diff line change
Expand Up @@ -5,7 +5,6 @@ import (
"context"
"reflect"
"runtime"
"sync"
"time"

"github.com/google/uuid"
Expand Down Expand Up @@ -107,7 +106,7 @@ func NewScheduler(options ...SchedulerOption) (Scheduler, error) {
exec := executor{
stopCh: make(chan struct{}),
stopTimeout: time.Second * 10,
singletonRunners: sync.Map{},
singletonRunners: nil,
logger: &noOpLogger{},

jobsIn: make(chan jobIn),
Expand Down

0 comments on commit 833690e

Please sign in to comment.