clean up PriorityFunction

zouyee · zouyee · commit 3512fde8c5df · 2019-11-08T12:33:21.000+08:00
Signed-off-by: Zou Nengren &lt;zouyee1989@gmail.com&gt;
diff --git a/pkg/scheduler/algorithm/priorities/balanced_resource_allocation_test.go b/pkg/scheduler/algorithm/priorities/balanced_resource_allocation_test.go
@@ -409,9 +409,8 @@ func TestBalancedResourceAllocation(t *testing.T) {
 					info.TransientInfo.TransNodeInfo.RequestedVolumes = len(test.pod.Spec.Volumes)
 				}
 			}
-			function := priorityFunction(BalancedResourceAllocationMap, nil, nil)
 
-			list, err := function(test.pod, snapshot, test.nodes)
+			list, err := runMapReducePriority(BalancedResourceAllocationMap, nil, nil, test.pod, snapshot, test.nodes)
 
 			if err != nil {
 				t.Errorf("unexpected error: %v", err)
diff --git a/pkg/scheduler/algorithm/priorities/image_locality_test.go b/pkg/scheduler/algorithm/priorities/image_locality_test.go
@@ -185,7 +185,7 @@ func TestImageLocalityPriority(t *testing.T) {
 	for _, test := range tests {
 		t.Run(test.name, func(t *testing.T) {
 			snapshot := nodeinfosnapshot.NewSnapshot(test.pods, test.nodes)
-			list, err := priorityFunction(ImageLocalityPriorityMap, nil, &priorityMetadata{totalNumNodes: len(test.nodes)})(test.pod, snapshot, test.nodes)
+			list, err := runMapReducePriority(ImageLocalityPriorityMap, nil, &priorityMetadata{totalNumNodes: len(test.nodes)}, test.pod, snapshot, test.nodes)
 			if err != nil {
 				t.Errorf("unexpected error: %v", err)
 			}
diff --git a/pkg/scheduler/algorithm/priorities/least_requested_test.go b/pkg/scheduler/algorithm/priorities/least_requested_test.go
@@ -254,7 +254,7 @@ func TestLeastRequested(t *testing.T) {
 	for _, test := range tests {
 		t.Run(test.name, func(t *testing.T) {
 			snapshot := nodeinfosnapshot.NewSnapshot(test.pods, test.nodes)
-			list, err := priorityFunction(LeastRequestedPriorityMap, nil, nil)(test.pod, snapshot, test.nodes)
+			list, err := runMapReducePriority(LeastRequestedPriorityMap, nil, nil, test.pod, snapshot, test.nodes)
 			if err != nil {
 				t.Errorf("unexpected error: %v", err)
 			}
diff --git a/pkg/scheduler/algorithm/priorities/most_requested_test.go b/pkg/scheduler/algorithm/priorities/most_requested_test.go
@@ -211,7 +211,7 @@ func TestMostRequested(t *testing.T) {
 	for _, test := range tests {
 		t.Run(test.name, func(t *testing.T) {
 			snapshot := nodeinfosnapshot.NewSnapshot(test.pods, test.nodes)
-			list, err := priorityFunction(MostRequestedPriorityMap, nil, nil)(test.pod, snapshot, test.nodes)
+			list, err := runMapReducePriority(MostRequestedPriorityMap, nil, nil, test.pod, snapshot, test.nodes)
 			if err != nil {
 				t.Errorf("unexpected error: %v", err)
 			}
diff --git a/pkg/scheduler/algorithm/priorities/node_affinity_test.go b/pkg/scheduler/algorithm/priorities/node_affinity_test.go
@@ -168,8 +168,7 @@ func TestNodeAffinityPriority(t *testing.T) {
 	for _, test := range tests {
 		t.Run(test.name, func(t *testing.T) {
 			snapshot := nodeinfosnapshot.NewSnapshot(nil, test.nodes)
-			nap := priorityFunction(CalculateNodeAffinityPriorityMap, CalculateNodeAffinityPriorityReduce, nil)
-			list, err := nap(test.pod, snapshot, test.nodes)
+			list, err := runMapReducePriority(CalculateNodeAffinityPriorityMap, CalculateNodeAffinityPriorityReduce, nil, test.pod, snapshot, test.nodes)
 			if err != nil {
 				t.Errorf("unexpected error: %v", err)
 			}
diff --git a/pkg/scheduler/algorithm/priorities/node_prefer_avoid_pods_test.go b/pkg/scheduler/algorithm/priorities/node_prefer_avoid_pods_test.go
@@ -142,7 +142,7 @@ func TestNodePreferAvoidPriority(t *testing.T) {
 	for _, test := range tests {
 		t.Run(test.name, func(t *testing.T) {
 			snapshot := nodeinfosnapshot.NewSnapshot(nil, test.nodes)
-			list, err := priorityFunction(CalculateNodePreferAvoidPodsPriorityMap, nil, nil)(test.pod, snapshot, test.nodes)
+			list, err := runMapReducePriority(CalculateNodePreferAvoidPodsPriorityMap, nil, nil, test.pod, snapshot, test.nodes)
 			if err != nil {
 				t.Errorf("unexpected error: %v", err)
 			}
diff --git a/pkg/scheduler/algorithm/priorities/requested_to_capacity_ratio_test.go b/pkg/scheduler/algorithm/priorities/requested_to_capacity_ratio_test.go
@@ -241,7 +241,7 @@ func TestRequestedToCapacityRatio(t *testing.T) {
 		newPod := buildResourcesPod("", test.requested)
 
 		snapshot := nodeinfosnapshot.NewSnapshot(scheduledPods, nodes)
-		list, err := priorityFunction(RequestedToCapacityRatioResourceAllocationPriorityDefault().PriorityMap, nil, nil)(newPod, snapshot, nodes)
+		list, err := runMapReducePriority(RequestedToCapacityRatioResourceAllocationPriorityDefault().PriorityMap, nil, nil, newPod, snapshot, nodes)
 		if err != nil {
 			t.Errorf("unexpected error: %v", err)
 		}
@@ -390,7 +390,7 @@ func TestResourceBinPackingSingleExtended(t *testing.T) {
 			functionShape, _ := NewFunctionShape([]FunctionShapePoint{{0, 0}, {100, 10}})
 			resourceToWeightMap := ResourceToWeightMap{v1.ResourceName("intel.com/foo"): 1}
 			prior := RequestedToCapacityRatioResourceAllocationPriority(functionShape, resourceToWeightMap)
-			list, err := priorityFunction(prior.PriorityMap, nil, nil)(test.pod, snapshot, test.nodes)
+			list, err := runMapReducePriority(prior.PriorityMap, nil, nil, test.pod, snapshot, test.nodes)
 			if err != nil {
 				t.Errorf("unexpected error: %v", err)
 			}
@@ -615,7 +615,7 @@ func TestResourceBinPackingMultipleExtended(t *testing.T) {
 			functionShape, _ := NewFunctionShape([]FunctionShapePoint{{0, 0}, {100, 10}})
 			resourceToWeightMap := ResourceToWeightMap{v1.ResourceName("intel.com/foo"): 3, v1.ResourceName("intel.com/bar"): 5}
 			prior := RequestedToCapacityRatioResourceAllocationPriority(functionShape, resourceToWeightMap)
-			list, err := priorityFunction(prior.PriorityMap, nil, nil)(test.pod, snapshot, test.nodes)
+			list, err := runMapReducePriority(prior.PriorityMap, nil, nil, test.pod, snapshot, test.nodes)
 			if err != nil {
 				t.Errorf("unexpected error: %v", err)
 			}
diff --git a/pkg/scheduler/algorithm/priorities/resource_limits.go b/pkg/scheduler/algorithm/priorities/resource_limits.go
@@ -19,7 +19,7 @@ package priorities
 import (
 	"fmt"
 
-	"k8s.io/api/core/v1"
+	v1 "k8s.io/api/core/v1"
 	framework "k8s.io/kubernetes/pkg/scheduler/framework/v1alpha1"
 	schedulernodeinfo "k8s.io/kubernetes/pkg/scheduler/nodeinfo"
 
@@ -43,7 +43,7 @@ func ResourceLimitsPriorityMap(pod *v1.Pod, meta interface{}, nodeInfo *schedule
 
 	// compute pod limits
 	var podLimits *schedulernodeinfo.Resource
-	if priorityMeta, ok := meta.(*priorityMetadata); ok {
+	if priorityMeta, ok := meta.(*priorityMetadata); ok && priorityMeta != nil {
 		// We were able to parse metadata, use podLimits from there.
 		podLimits = priorityMeta.podLimits
 	} else {
diff --git a/pkg/scheduler/algorithm/priorities/resource_limits_test.go b/pkg/scheduler/algorithm/priorities/resource_limits_test.go
@@ -20,7 +20,7 @@ import (
 	"reflect"
 	"testing"
 
-	"k8s.io/api/core/v1"
+	v1 "k8s.io/api/core/v1"
 	"k8s.io/apimachinery/pkg/api/resource"
 	framework "k8s.io/kubernetes/pkg/scheduler/framework/v1alpha1"
 	nodeinfosnapshot "k8s.io/kubernetes/pkg/scheduler/nodeinfo/snapshot"
@@ -144,14 +144,12 @@ func TestResourceLimitsPriority(t *testing.T) {
 			}
 
 			for _, hasMeta := range []bool{true, false} {
-				var function PriorityFunction
-				if hasMeta {
-					function = priorityFunction(ResourceLimitsPriorityMap, nil, metadata)
-				} else {
-					function = priorityFunction(ResourceLimitsPriorityMap, nil, nil)
+				meta := metadata
+				if !hasMeta {
+					meta = nil
 				}
 
-				list, err := function(test.pod, snapshot, test.nodes)
+				list, err := runMapReducePriority(ResourceLimitsPriorityMap, nil, meta, test.pod, snapshot, test.nodes)
 
 				if err != nil {
 					t.Errorf("unexpected error: %v", err)
diff --git a/pkg/scheduler/algorithm/priorities/selector_spreading_test.go b/pkg/scheduler/algorithm/priorities/selector_spreading_test.go
@@ -355,8 +355,7 @@ func TestSelectorSpreadPriority(t *testing.T) {
 			)
 			metaData := metaDataProducer(test.pod, nodes, snapshot)
 
-			ttp := priorityFunction(selectorSpread.CalculateSpreadPriorityMap, selectorSpread.CalculateSpreadPriorityReduce, metaData)
-			list, err := ttp(test.pod, snapshot, makeNodeList(test.nodes))
+			list, err := runMapReducePriority(selectorSpread.CalculateSpreadPriorityMap, selectorSpread.CalculateSpreadPriorityReduce, metaData, test.pod, snapshot, makeNodeList(test.nodes))
 			if err != nil {
 				t.Errorf("unexpected error: %v \n", err)
 			}
@@ -593,8 +592,7 @@ func TestZoneSelectorSpreadPriority(t *testing.T) {
 				1,
 			)
 			metaData := metaDataProducer(test.pod, nodes, snapshot)
-			ttp := priorityFunction(selectorSpread.CalculateSpreadPriorityMap, selectorSpread.CalculateSpreadPriorityReduce, metaData)
-			list, err := ttp(test.pod, snapshot, makeLabeledNodeList(labeledNodes))
+			list, err := runMapReducePriority(selectorSpread.CalculateSpreadPriorityMap, selectorSpread.CalculateSpreadPriorityReduce, metaData, test.pod, snapshot, makeLabeledNodeList(labeledNodes))
 			if err != nil {
 				t.Errorf("unexpected error: %v", err)
 			}
@@ -783,8 +781,7 @@ func TestZoneSpreadPriority(t *testing.T) {
 				1,
 			)
 			metaData := metaDataProducer(test.pod, nodes, snapshot)
-			ttp := priorityFunction(zoneSpread.CalculateAntiAffinityPriorityMap, zoneSpread.CalculateAntiAffinityPriorityReduce, metaData)
-			list, err := ttp(test.pod, snapshot, makeLabeledNodeList(test.nodes))
+			list, err := runMapReducePriority(zoneSpread.CalculateAntiAffinityPriorityMap, zoneSpread.CalculateAntiAffinityPriorityReduce, metaData, test.pod, snapshot, makeLabeledNodeList(test.nodes))
 			if err != nil {
 				t.Errorf("unexpected error: %v", err)
 			}
diff --git a/pkg/scheduler/algorithm/priorities/spreading_perf_test.go b/pkg/scheduler/algorithm/priorities/spreading_perf_test.go
@@ -98,8 +98,7 @@ func BenchmarkTestSelectorSpreadPriority(b *testing.B) {
 				meta := &priorityMetadata{
 					podSelectors: getSelectors(pod, ss.serviceLister, ss.controllerLister, ss.replicaSetLister, ss.statefulSetLister),
 				}
-				ttp := priorityFunction(ss.CalculateSpreadPriorityMap, ss.CalculateSpreadPriorityReduce, meta)
-				_, err := ttp(pod, snapshot, filteredNodes)
+				_, err := runMapReducePriority(ss.CalculateSpreadPriorityMap, ss.CalculateSpreadPriorityReduce, meta, pod, snapshot, filteredNodes)
 				if err != nil {
 					b.Fatal(err)
 				}
diff --git a/pkg/scheduler/algorithm/priorities/taint_toleration_test.go b/pkg/scheduler/algorithm/priorities/taint_toleration_test.go
@@ -228,8 +228,7 @@ func TestTaintAndToleration(t *testing.T) {
 	for _, test := range tests {
 		t.Run(test.name, func(t *testing.T) {
 			snapshot := nodeinfosnapshot.NewSnapshot(nil, test.nodes)
-			ttp := priorityFunction(ComputeTaintTolerationPriorityMap, ComputeTaintTolerationPriorityReduce, nil)
-			list, err := ttp(test.pod, snapshot, test.nodes)
+			list, err := runMapReducePriority(ComputeTaintTolerationPriorityMap, ComputeTaintTolerationPriorityReduce, nil, test.pod, snapshot, test.nodes)
 			if err != nil {
 				t.Errorf("unexpected error: %v", err)
 			}
diff --git a/pkg/scheduler/algorithm/priorities/test_util.go b/pkg/scheduler/algorithm/priorities/test_util.go
@@ -19,7 +19,7 @@ package priorities
 import (
 	"sort"
 
-	"k8s.io/api/core/v1"
+	v1 "k8s.io/api/core/v1"
 	"k8s.io/apimachinery/pkg/api/resource"
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
 	framework "k8s.io/kubernetes/pkg/scheduler/framework/v1alpha1"
@@ -58,27 +58,25 @@ func makeNodeWithExtendedResource(node string, milliCPU, memory int64, extendedR
 	}
 }
 
-func priorityFunction(mapFn PriorityMapFunction, reduceFn PriorityReduceFunction, metaData interface{}) PriorityFunction {
-	return func(pod *v1.Pod, sharedLister schedulerlisters.SharedLister, nodes []*v1.Node) (framework.NodeScoreList, error) {
-		result := make(framework.NodeScoreList, 0, len(nodes))
-		for i := range nodes {
-			nodeInfo, err := sharedLister.NodeInfos().Get(nodes[i].Name)
-			if err != nil {
-				return nil, err
-			}
-			hostResult, err := mapFn(pod, metaData, nodeInfo)
-			if err != nil {
-				return nil, err
-			}
-			result = append(result, hostResult)
+func runMapReducePriority(mapFn PriorityMapFunction, reduceFn PriorityReduceFunction, metaData interface{}, pod *v1.Pod, sharedLister schedulerlisters.SharedLister, nodes []*v1.Node) (framework.NodeScoreList, error) {
+	result := make(framework.NodeScoreList, 0, len(nodes))
+	for i := range nodes {
+		nodeInfo, err := sharedLister.NodeInfos().Get(nodes[i].Name)
+		if err != nil {
+			return nil, err
 		}
-		if reduceFn != nil {
-			if err := reduceFn(pod, metaData, sharedLister, result); err != nil {
-				return nil, err
-			}
+		hostResult, err := mapFn(pod, metaData, nodeInfo)
+		if err != nil {
+			return nil, err
 		}
-		return result, nil
+		result = append(result, hostResult)
 	}
+	if reduceFn != nil {
+		if err := reduceFn(pod, metaData, sharedLister, result); err != nil {
+			return nil, err
+		}
+	}
+	return result, nil
 }
 
 func sortNodeScoreList(out framework.NodeScoreList) {
diff --git a/pkg/scheduler/algorithm/priorities/types.go b/pkg/scheduler/algorithm/priorities/types.go
@@ -38,11 +38,6 @@ type PriorityReduceFunction func(pod *v1.Pod, meta interface{}, sharedLister sch
 // is now used for only for priority functions. For predicates please use PredicateMetadataProducer.
 type PriorityMetadataProducer func(pod *v1.Pod, filteredNodes []*v1.Node, sharedLister schedulerlisters.SharedLister) interface{}
 
-// PriorityFunction is a function that computes scores for all nodes.
-// DEPRECATED
-// Use Map-Reduce pattern for priority functions.
-type PriorityFunction func(pod *v1.Pod, sharedLister schedulerlisters.SharedLister, nodes []*v1.Node) (framework.NodeScoreList, error)
-
 // PriorityConfig is a config used for a priority function.
 type PriorityConfig struct {
 	Name   string
diff --git a/pkg/scheduler/algorithm_factory.go b/pkg/scheduler/algorithm_factory.go
@@ -70,19 +70,13 @@ type PredicateMetadataProducerFactory func(PluginFactoryArgs) predicates.Predica
 // FitPredicateFactory produces a FitPredicate from the given args.
 type FitPredicateFactory func(PluginFactoryArgs) predicates.FitPredicate
 
-// PriorityFunctionFactory produces a PriorityConfig from the given args.
-// DEPRECATED
-// Use Map-Reduce pattern for priority functions.
-type PriorityFunctionFactory func(PluginFactoryArgs) priorities.PriorityFunction
-
-// PriorityFunctionFactory2 produces map & reduce priority functions
+// PriorityFunctionFactory produces map & reduce priority functions
 // from a given args.
-// FIXME: Rename to PriorityFunctionFactory.
-type PriorityFunctionFactory2 func(PluginFactoryArgs) (priorities.PriorityMapFunction, priorities.PriorityReduceFunction)
+type PriorityFunctionFactory func(PluginFactoryArgs) (priorities.PriorityMapFunction, priorities.PriorityReduceFunction)
 
 // PriorityConfigFactory produces a PriorityConfig from the given function and weight
 type PriorityConfigFactory struct {
-	MapReduceFunction PriorityFunctionFactory2
+	MapReduceFunction PriorityFunctionFactory
 	Weight            int64
 }
 

Original file line number	Diff line number	Diff line change
`@@ -409,9 +409,8 @@ func TestBalancedResourceAllocation(t *testing.T) {`
`409`	`409`	`info.TransientInfo.TransNodeInfo.RequestedVolumes = len(test.pod.Spec.Volumes)`
`410`	`410`	`}`
`411`	`411`	`}`
`412`		`- function := priorityFunction(BalancedResourceAllocationMap, nil, nil)`
`413`	`412`
`414`		`- list, err := function(test.pod, snapshot, test.nodes)`
	`413`	`+ list, err := runMapReducePriority(BalancedResourceAllocationMap, nil, nil, test.pod, snapshot, test.nodes)`
`415`	`414`
`416`	`415`	`if err != nil {`
`417`	`416`	`t.Errorf("unexpected error: %v", err)`
Original file line number	Diff line number	Diff line change
`@@ -185,7 +185,7 @@ func TestImageLocalityPriority(t *testing.T) {`
`185`	`185`	`for _, test := range tests {`
`186`	`186`	`t.Run(test.name, func(t *testing.T) {`
`187`	`187`	`snapshot := nodeinfosnapshot.NewSnapshot(test.pods, test.nodes)`
`188`		`- list, err := priorityFunction(ImageLocalityPriorityMap, nil, &priorityMetadata{totalNumNodes: len(test.nodes)})(test.pod, snapshot, test.nodes)`
	`188`	`+ list, err := runMapReducePriority(ImageLocalityPriorityMap, nil, &priorityMetadata{totalNumNodes: len(test.nodes)}, test.pod, snapshot, test.nodes)`
`189`	`189`	`if err != nil {`
`190`	`190`	`t.Errorf("unexpected error: %v", err)`
`191`	`191`	`}`
Original file line number	Diff line number	Diff line change
`@@ -254,7 +254,7 @@ func TestLeastRequested(t *testing.T) {`
`254`	`254`	`for _, test := range tests {`
`255`	`255`	`t.Run(test.name, func(t *testing.T) {`
`256`	`256`	`snapshot := nodeinfosnapshot.NewSnapshot(test.pods, test.nodes)`
`257`		`- list, err := priorityFunction(LeastRequestedPriorityMap, nil, nil)(test.pod, snapshot, test.nodes)`
	`257`	`+ list, err := runMapReducePriority(LeastRequestedPriorityMap, nil, nil, test.pod, snapshot, test.nodes)`
`258`	`258`	`if err != nil {`
`259`	`259`	`t.Errorf("unexpected error: %v", err)`
`260`	`260`	`}`
Original file line number	Diff line number	Diff line change
`@@ -211,7 +211,7 @@ func TestMostRequested(t *testing.T) {`
`211`	`211`	`for _, test := range tests {`
`212`	`212`	`t.Run(test.name, func(t *testing.T) {`
`213`	`213`	`snapshot := nodeinfosnapshot.NewSnapshot(test.pods, test.nodes)`
`214`		`- list, err := priorityFunction(MostRequestedPriorityMap, nil, nil)(test.pod, snapshot, test.nodes)`
	`214`	`+ list, err := runMapReducePriority(MostRequestedPriorityMap, nil, nil, test.pod, snapshot, test.nodes)`
`215`	`215`	`if err != nil {`
`216`	`216`	`t.Errorf("unexpected error: %v", err)`
`217`	`217`	`}`
Original file line number	Diff line number	Diff line change
`@@ -142,7 +142,7 @@ func TestNodePreferAvoidPriority(t *testing.T) {`
`142`	`142`	`for _, test := range tests {`
`143`	`143`	`t.Run(test.name, func(t *testing.T) {`
`144`	`144`	`snapshot := nodeinfosnapshot.NewSnapshot(nil, test.nodes)`
`145`		`- list, err := priorityFunction(CalculateNodePreferAvoidPodsPriorityMap, nil, nil)(test.pod, snapshot, test.nodes)`
	`145`	`+ list, err := runMapReducePriority(CalculateNodePreferAvoidPodsPriorityMap, nil, nil, test.pod, snapshot, test.nodes)`
`146`	`146`	`if err != nil {`
`147`	`147`	`t.Errorf("unexpected error: %v", err)`
`148`	`148`	`}`
Original file line number	Diff line number	Diff line change
`@@ -355,8 +355,7 @@ func TestSelectorSpreadPriority(t *testing.T) {`
`355`	`355`	`)`
`356`	`356`	`metaData := metaDataProducer(test.pod, nodes, snapshot)`
`357`	`357`
`358`		`- ttp := priorityFunction(selectorSpread.CalculateSpreadPriorityMap, selectorSpread.CalculateSpreadPriorityReduce, metaData)`
`359`		`- list, err := ttp(test.pod, snapshot, makeNodeList(test.nodes))`
	`358`	`+ list, err := runMapReducePriority(selectorSpread.CalculateSpreadPriorityMap, selectorSpread.CalculateSpreadPriorityReduce, metaData, test.pod, snapshot, makeNodeList(test.nodes))`
`360`	`359`	`if err != nil {`
`361`	`360`	`t.Errorf("unexpected error: %v \n", err)`
`362`	`361`	`}`
`@@ -593,8 +592,7 @@ func TestZoneSelectorSpreadPriority(t *testing.T) {`
`593`	`592`	`1,`
`594`	`593`	`)`
`595`	`594`	`metaData := metaDataProducer(test.pod, nodes, snapshot)`
`596`		`- ttp := priorityFunction(selectorSpread.CalculateSpreadPriorityMap, selectorSpread.CalculateSpreadPriorityReduce, metaData)`
`597`		`- list, err := ttp(test.pod, snapshot, makeLabeledNodeList(labeledNodes))`
	`595`	`+ list, err := runMapReducePriority(selectorSpread.CalculateSpreadPriorityMap, selectorSpread.CalculateSpreadPriorityReduce, metaData, test.pod, snapshot, makeLabeledNodeList(labeledNodes))`
`598`	`596`	`if err != nil {`
`599`	`597`	`t.Errorf("unexpected error: %v", err)`
`600`	`598`	`}`
`@@ -783,8 +781,7 @@ func TestZoneSpreadPriority(t *testing.T) {`
`783`	`781`	`1,`
`784`	`782`	`)`
`785`	`783`	`metaData := metaDataProducer(test.pod, nodes, snapshot)`
`786`		`- ttp := priorityFunction(zoneSpread.CalculateAntiAffinityPriorityMap, zoneSpread.CalculateAntiAffinityPriorityReduce, metaData)`
`787`		`- list, err := ttp(test.pod, snapshot, makeLabeledNodeList(test.nodes))`
	`784`	`+ list, err := runMapReducePriority(zoneSpread.CalculateAntiAffinityPriorityMap, zoneSpread.CalculateAntiAffinityPriorityReduce, metaData, test.pod, snapshot, makeLabeledNodeList(test.nodes))`
`788`	`785`	`if err != nil {`
`789`	`786`	`t.Errorf("unexpected error: %v", err)`
`790`	`787`	`}`