fix: don't release on started

hatchet-dev · Oct 2, 2024 · 7647c28 · 7647c28
1 parent a56629b
commit 7647c28
Showing 1 changed file with 0 additions and 6 deletions.
diff --git a/internal/services/dispatcher/server.go b/internal/services/dispatcher/server.go
@@ -1064,12 +1064,6 @@ func (s *DispatcherImpl) handleStepRunStarted(ctx context.Context, request *cont
 		TenantId: tenantId,
 	})
 
-	err = s.repo.StepRun().ReleaseStepRunSemaphore(ctx, tenantId, request.StepRunId, false)
-
-	if err != nil {
-		s.l.Error().Err(err).Msgf("could not release semaphore for step run %s", request.StepRunId)
-	}
-
 	// send the event to the jobs queue
 	err = s.mq.AddMessage(ctx, msgqueue.JOB_PROCESSING_QUEUE, &msgqueue.Message{
 		ID:       "step-run-started",