diff --git a/workflow/sync/multi_throttler.go b/workflow/sync/multi_throttler.go index 75b2396c6fb4..7af9fafbf302 100644 --- a/workflow/sync/multi_throttler.go +++ b/workflow/sync/multi_throttler.go @@ -145,6 +145,7 @@ func (m *multiThrottler) Remove(key Key) { delete(m.running, key) m.namespaceCounts[namespace] = m.namespaceCounts[namespace] - 1 } + m.pending[namespace].remove(key) m.queueThrottled() }