From bcf51c36cb5044b6abc32cacf4b66391245cb919 Mon Sep 17 00:00:00 2001 From: Peter Amstutz Date: Fri, 29 Mar 2019 14:28:01 -0400 Subject: [PATCH] 15050: Need to make sure to raise the semaphore when we're done Arvados-DCO-1.1-Signed-off-by: Peter Amstutz --- services/crunch-dispatch-local/crunch-dispatch-local.go | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/services/crunch-dispatch-local/crunch-dispatch-local.go b/services/crunch-dispatch-local/crunch-dispatch-local.go index 36d149272f..62935447dd 100644 --- a/services/crunch-dispatch-local/crunch-dispatch-local.go +++ b/services/crunch-dispatch-local/crunch-dispatch-local.go @@ -153,7 +153,10 @@ func (lr *LocalRun) run(dispatcher *dispatch.Dispatcher, return } + defer func() { <-lr.concurrencyLimit }() + waitGroup.Add(1) + defer waitGroup.Done() cmd := exec.Command(*crunchRunCommand, uuid) cmd.Stdin = nil @@ -207,7 +210,6 @@ func (lr *LocalRun) run(dispatcher *dispatch.Dispatcher, delete(runningCmds, uuid) runningCmdsMutex.Unlock() } - waitGroup.Done() } // If the container is not finalized, then change it to "Cancelled". -- 2.30.2