Method waitWorkers

src/go/plugin/framework/functions/manager.go:243–263

(workersWG *sync.WaitGroup)

}

func (m *Manager) waitWorkers(workersWG *sync.WaitGroup) bool {
	if workersWG == nil {
		return false
	}

	drainCtx, cancelDrain := context.WithTimeout(context.Background(), m.shutdownDrainTimeout)
	defer cancelDrain()

	done := make(chan struct{})
	go func() {
		defer close(done)
		workersWG.Wait()
	}()

	select {
	case <-done:
		return false
	case <-drainCtx.Done():
		return true
	}
}

func (m *Manager) finalizeUnresolvedOnShutdown(cancelInflight, timedOut bool) {
	if !cancelInflight {