Merge pull request #117 from sgotti/executor_add_missing_mutex_unlock
executor: add missing mutex unlock
This commit is contained in:
commit
eddb62b6e2
@ -778,6 +778,7 @@ func (e *Executor) executeTask(ctx context.Context, et *types.ExecutorTask) {
|
|||||||
|
|
||||||
if !e.runningTasks.addIfNotExists(et.ID, rt) {
|
if !e.runningTasks.addIfNotExists(et.ID, rt) {
|
||||||
log.Debugf("task %s already running", et.ID)
|
log.Debugf("task %s already running", et.ID)
|
||||||
|
rt.Unlock()
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
|
Loading…
Reference in New Issue
Block a user