Method tryFinalize

src/go/plugin/framework/functions/manager.go:592–624

tryFinalize emits a terminal response once per transaction UID. Later terminal attempts for the same UID are dropped while tombstone is active.

(uid, source string, emit func())

// tryFinalize emits a terminal response once per transaction UID.
// Later terminal attempts for the same UID are dropped while tombstone is active.
func (m *Manager) tryFinalize(uid, source string, emit func()) bool {
	if uid == "" || emit == nil {
		return false
	}

	m.invStateMux.Lock()
	now := time.Now()
	m.pruneExpiredTombstonesLocked(now)
	if _, ok := m.tombstones[uid]; ok {
		m.invStateMux.Unlock()
		m.Debugf("dropping late terminal response for uid '%s' (source=%s)", uid, source)
		m.observeLateTerminalDropped()
		return false
	}

	var scheduleKey string
	if rec, ok := m.invState[uid]; ok && rec != nil {
		m.stopTimersLocked(rec)
		scheduleKey = rec.scheduleKey
	}
	delete(m.invState, uid)
	m.tombstones[uid] = now.Add(m.tombstoneTTL)
	m.observeInvocationsLocked()
	m.invStateMux.Unlock()

	if scheduleKey != "" && m.scheduler != nil {
		m.scheduler.complete(scheduleKey, uid)
		m.observeSchedulerPending()
	}

	emit()
	return true
}

func (m *Manager) pruneExpiredTombstonesLocked(now time.Time) {
	for uid, expiresAt := range m.tombstones {