Skip to content

Commit

Permalink
Merge pull request #752 from k8up-io/fix/decrease_queue
Browse files Browse the repository at this point in the history
Decrease the queue counter unconditionally
  • Loading branch information
ccremer authored Oct 20, 2022
2 parents 3dde1a8 + d517577 commit a11effe
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion operator/queue/execution.go
Original file line number Diff line number Diff line change
@@ -87,8 +87,8 @@ func (eq *ExecutionQueue) Get(repository string) Executor {
entry := eq.queues[repository].get()
if eq.queues[repository].Len() == 0 {
delete(eq.queues, repository)
eq.decQueueGauge(entry.GetJobNamespace(), entry.GetJobType())
}
eq.decQueueGauge(entry.GetJobNamespace(), entry.GetJobType())
return entry
}

0 comments on commit a11effe

Please sign in to comment.