write correct map

hatchet-dev · Aug 20, 2024 · 895795b · 895795b
1 parent 6a6fa0f
commit 895795b
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/internal/services/controllers/jobs/controller.go b/internal/services/controllers/jobs/controller.go
@@ -840,7 +840,7 @@ func (jc *JobsControllerImpl) runStepRunTimeout(ctx context.Context) func() {
 func (ec *JobsControllerImpl) runStepRunTimeoutTenant(ctx context.Context, tenantId string) error {
 	// we want only one requeue running at a time for a tenant
 	if _, ok := ec.timeoutMutexes.Load(tenantId); !ok {
-		ec.reassignMutexes.Store(tenantId, &sync.Mutex{})
+		ec.timeoutMutexes.Store(tenantId, &sync.Mutex{})
 	}
 
 	muInt, _ := ec.timeoutMutexes.Load(tenantId)