func runConnectivityProbes()

in pkg/scheduler/scheduler.go [253:260]

• 8 lines of code
• 3 McCabe index (conditional complexity)

func runConnectivityProbes(ctx context.Context, recorder metrics.ProbeRecorder, probes probe.ConnectivityProbeMap) {
	for name, pr := range probes {
		err := pr.Run(ctx, recorder)
		if err != nil {
			klog.Warningf("probe %q returned unexpected error %v\n", name, err)
		}
	}
}