@@ -1081,21 +1081,8 @@ func TestPriorityQueue(t *testing.T) {
10811081 }
10821082
10831083 mu .Lock ()
1084- // Check if the expected order is either {0, 6, 7, ...} or {0, 7, 6, ...}
1085- // This is because while tasks are dequeued in order, they can run asynchronously
1086- // and one could set a value in wfPriorityList before the other
1087- expectedOrder1 := []int {0 , 6 , 7 , 1 , 2 , 3 , 4 , 5 }
1088- expectedOrder2 := []int {0 , 7 , 6 , 1 , 2 , 3 , 4 , 5 }
1089-
1090- validOrder := false
1091- if reflect .DeepEqual (wfPriorityList , expectedOrder1 ) {
1092- validOrder = true
1093- } else if reflect .DeepEqual (wfPriorityList , expectedOrder2 ) {
1094- validOrder = true
1095- }
1096-
1097- assert .True (t , validOrder , "expected workflow execution order to be either %v or %v, got %v" ,
1098- expectedOrder1 , expectedOrder2 , wfPriorityList )
1084+ expectedOrder := []int {0 , 6 , 7 , 1 , 2 , 3 , 4 , 5 }
1085+ assert .True (t , reflect .DeepEqual (wfPriorityList , expectedOrder ), "expected workflow execution order to be %v, got %v" , expectedOrder , wfPriorityList )
10991086 mu .Unlock ()
11001087
11011088 // Verify that handle6 and handle7 workflows were dequeued in FIFO order
0 commit comments