oops...

hatchet-dev · Aug 1, 2024 · a5e249e · a5e249e
1 parent 24b5046
commit a5e249e
Showing 1 changed file with 10 additions and 8 deletions.
diff --git a/internal/services/controllers/jobs/controller.go b/internal/services/controllers/jobs/controller.go
@@ -136,14 +136,16 @@ func New(fs ...JobsControllerOpt) (*JobsControllerImpl, error) {
 	a.WithData(map[string]interface{}{"service": "jobs-controller"})
 
 	return &JobsControllerImpl{
-		mq:             opts.mq,
-		l:              opts.l,
-		repo:           opts.repo,
-		dv:             opts.dv,
-		s:              s,
-		a:              a,
-		partitionId:    opts.partitionId,
-		requeueMutexes: make(map[string]*sync.Mutex),
+		mq:              opts.mq,
+		l:               opts.l,
+		repo:            opts.repo,
+		dv:              opts.dv,
+		s:               s,
+		a:               a,
+		partitionId:     opts.partitionId,
+		requeueMutexes:  make(map[string]*sync.Mutex),
+		reassignMutexes: make(map[string]*sync.Mutex),
+		timeoutMutexes:  make(map[string]*sync.Mutex),
 	}, nil
 }