@@ -453,7 +453,6 @@ func TestPrepareCandidate(t *testing.T) {
453
453
expectedStatus * framework.Status
454
454
// Only compared when async preemption is enabled.
455
455
expectedPreemptingMap sets.Set [types.UID ]
456
- expectedActivatedPods map [string ]* v1.Pod
457
456
}{
458
457
{
459
458
name : "no victims" ,
@@ -468,7 +467,6 @@ func TestPrepareCandidate(t *testing.T) {
468
467
nodeNames : []string {node1Name },
469
468
expectedStatus : nil ,
470
469
expectedPreemptingMap : sets .New (types .UID ("preemptor" )),
471
- expectedActivatedPods : map [string ]* v1.Pod {preemptor .Name : preemptor },
472
470
},
473
471
{
474
472
name : "one victim without condition" ,
@@ -489,7 +487,6 @@ func TestPrepareCandidate(t *testing.T) {
489
487
expectedDeletedPods : []string {"victim1" },
490
488
expectedStatus : nil ,
491
489
expectedPreemptingMap : sets .New (types .UID ("preemptor" )),
492
- expectedActivatedPods : map [string ]* v1.Pod {preemptor .Name : preemptor },
493
490
},
494
491
{
495
492
name : "one victim with same condition" ,
@@ -510,7 +507,6 @@ func TestPrepareCandidate(t *testing.T) {
510
507
expectedDeletedPods : []string {"victim1" },
511
508
expectedStatus : nil ,
512
509
expectedPreemptingMap : sets .New (types .UID ("preemptor" )),
513
- expectedActivatedPods : map [string ]* v1.Pod {preemptor .Name : preemptor },
514
510
},
515
511
{
516
512
name : "one victim, not-found victim error is ignored when patching" ,
@@ -529,7 +525,6 @@ func TestPrepareCandidate(t *testing.T) {
529
525
expectedDeletedPods : []string {"victim1" },
530
526
expectedStatus : nil ,
531
527
expectedPreemptingMap : sets .New (types .UID ("preemptor" )),
532
- expectedActivatedPods : map [string ]* v1.Pod {preemptor .Name : preemptor },
533
528
},
534
529
{
535
530
name : "one victim, but pod deletion failed" ,
@@ -548,7 +543,6 @@ func TestPrepareCandidate(t *testing.T) {
548
543
nodeNames : []string {node1Name },
549
544
expectedStatus : framework .AsStatus (errors .New ("delete pod failed" )),
550
545
expectedPreemptingMap : sets .New (types .UID ("preemptor" )),
551
- expectedActivatedPods : map [string ]* v1.Pod {preemptor .Name : preemptor },
552
546
},
553
547
{
554
548
name : "one victim, not-found victim error is ignored when deleting" ,
@@ -567,7 +561,6 @@ func TestPrepareCandidate(t *testing.T) {
567
561
expectedDeletedPods : []string {"victim1" },
568
562
expectedStatus : nil ,
569
563
expectedPreemptingMap : sets .New (types .UID ("preemptor" )),
570
- expectedActivatedPods : map [string ]* v1.Pod {preemptor .Name : preemptor },
571
564
},
572
565
{
573
566
name : "one victim, but patch pod failed" ,
@@ -586,7 +579,6 @@ func TestPrepareCandidate(t *testing.T) {
586
579
nodeNames : []string {node1Name },
587
580
expectedStatus : framework .AsStatus (errors .New ("patch pod status failed" )),
588
581
expectedPreemptingMap : sets .New (types .UID ("preemptor" )),
589
- expectedActivatedPods : map [string ]* v1.Pod {preemptor .Name : preemptor },
590
582
},
591
583
{
592
584
name : "two victims without condition, one passes successfully and the second fails" ,
@@ -609,7 +601,6 @@ func TestPrepareCandidate(t *testing.T) {
609
601
expectedDeletedPods : []string {"victim2" },
610
602
expectedStatus : framework .AsStatus (errors .New ("patch pod status failed" )),
611
603
expectedPreemptingMap : sets .New (types .UID ("preemptor" )),
612
- expectedActivatedPods : map [string ]* v1.Pod {preemptor .Name : preemptor },
613
604
},
614
605
}
615
606
@@ -739,12 +730,9 @@ func TestPrepareCandidate(t *testing.T) {
739
730
}
740
731
741
732
if asyncPreemptionEnabled {
742
- if tt .expectedActivatedPods != nil && ! reflect .DeepEqual (tt .expectedActivatedPods , fakeActivator .activatedPods ) {
743
- lastErrMsg = fmt .Sprintf ("expected activated pods %v, got %v" , tt .expectedActivatedPods , fakeActivator .activatedPods )
744
- return false , nil
745
- }
746
- if tt .expectedActivatedPods == nil && len (fakeActivator .activatedPods ) != 0 {
747
- lastErrMsg = fmt .Sprintf ("expected no activated pods, got %v" , fakeActivator .activatedPods )
733
+ // Make sure the preemptor is activated regardless of the preemption result.
734
+ if ! reflect .DeepEqual (map [string ]* v1.Pod {tt .preemptor .Name : tt .preemptor }, fakeActivator .activatedPods ) {
735
+ lastErrMsg = fmt .Sprintf ("expected activated pods %v, got %v" , map [string ]* v1.Pod {tt .preemptor .Name : tt .preemptor }, fakeActivator .activatedPods )
748
736
return false , nil
749
737
}
750
738
}
0 commit comments