revert test suite

HDT3213 · Feb 16, 2024 · f63cf13 · f63cf13
1 parent 2e259ed
commit f63cf13
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/delayqueue_test.go b/delayqueue_test.go
@@ -36,7 +36,7 @@ func TestDelayQueue_consume(t *testing.T) {
 			t.Error(err)
 		}
 	}
-	for i := 0; i < 10; i++ {
+	for i := 0; i < 10*size; i++ {
 		err := queue.consume()
 		if err != nil {
 			t.Errorf("consume error: %v", err)
@@ -85,7 +85,7 @@ func TestDelayQueueOnCluster(t *testing.T) {
 			t.Error(err)
 		}
 	}
-	for i := 0; i < size; i++ {
+	for i := 0; i < 10*size; i++ {
 		err := queue.consume()
 		if err != nil {
 			t.Errorf("consume error: %v", err)