remove tag from pending if already removed

garmr-ulfr · garmr-ulfr · commit 72abe52a7fed · 2025-12-31T12:06:10.000-08:00
diff --git a/adapter/groups/manager.go b/adapter/groups/manager.go
@@ -321,6 +321,7 @@ func (rq *removalQueue) checkPending() {
 			// double check if outbound/endpoint still exists
 			if _, exists = rq.outMgr.Outbound(tag); !exists {
 				rq.logger.Trace("outbound already removed", "tag", tag)
+				delete(rq.pending, tag)
 				continue
 			}
 			rq.logger.Debug("removing outbound", "tag", tag)

Original file line number	Diff line number	Diff line change
`@@ -321,6 +321,7 @@ func (rq *removalQueue) checkPending() {`
`321`	`321`	`// double check if outbound/endpoint still exists`
`322`	`322`	`if _, exists = rq.outMgr.Outbound(tag); !exists {`
`323`	`323`	`rq.logger.Trace("outbound already removed", "tag", tag)`
	`324`	`+ delete(rq.pending, tag)`
`324`	`325`	`continue`
`325`	`326`	`}`
`326`	`327`	`rq.logger.Debug("removing outbound", "tag", tag)`