func()

in pkg/azure/nodetaint_utils.go [63:79]

• 17 lines of code
• 4 McCabe index (conditional complexity)

func (az *azClient) WaitForNodeIpGroupUpdate(ctx context.Context, nodesWithFwTaint []*corev1.Node, pollers map[string]*runtime.Poller[a.IPGroupsClientCreateOrUpdateResponse]) {
	var wg sync.WaitGroup
	for _, poller := range pollers {
		wg.Add(1)
		go func(poller *runtime.Poller[a.IPGroupsClientCreateOrUpdateResponse]) {
			_, err := poller.PollUntilDone(ctx, nil)
			if err != nil {
				klog.Error("failed to pull the result: %v", err)
			}
			defer wg.Done()
		}(poller)
	}
	wg.Wait()
	for _, node := range nodesWithFwTaint {
		az.RemoveTaints(ctx, node)
	}
}