diff --git a/cmd/tap/outbox.go b/cmd/tap/outbox.go index 802f8f4a..08653b5e 100644 --- a/cmd/tap/outbox.go +++ b/cmd/tap/outbox.go @@ -262,13 +262,8 @@ func (w *DIDWorker) processPendingEvts() { w.mu.Lock() if w.blockedOnLive { - if len(w.inFlightSentAt) == 0 { - // nothing in flight, proceed to processing - w.blockedOnLive = false - } else { - w.mu.Unlock() - return - } + w.mu.Unlock() + return } if len(w.pendingEvts) == 0 {