executor: add missing mutex unlock

Add missing mutex unlock that will cause deadlocks.
2019-09-17 23:32:23 +02:00 · 2019-09-17 23:32:23 +02:00 · 714da3ffe3
parent 9f1a3e405d
commit 714da3ffe3
1 changed files with 1 additions and 0 deletions
--- a/internal/services/executor/executor.go
+++ b/internal/services/executor/executor.go
@ -778,6 +778,7 @@ func (e *Executor) executeTask(ctx context.Context, et *types.ExecutorTask) {

 	if !e.runningTasks.addIfNotExists(et.ID, rt) {
 		log.Debugf("task %s already running", et.ID)
+		rt.Unlock()
 		return
 	}