From 6bd5a4c3b100654f8a8a7423f011d7682e97b5f5 Mon Sep 17 00:00:00 2001
From: ale <ale@incal.net>
Date: Sat, 13 Feb 2021 12:18:30 +0000
Subject: [PATCH] Mark tests as parallelizable
---
engine/debug_test.go | 2 ++
engine/enq_test.go | 12 ++++++++++++
2 files changed, 14 insertions(+)
diff --git a/engine/debug_test.go b/engine/debug_test.go
index 73da58f5..36e17637 100644
--- a/engine/debug_test.go
+++ b/engine/debug_test.go
@@ -14,6 +14,8 @@ import (
)
func TestDebug(t *testing.T) {
+ t.Parallel()
+
n := newTestNet()
defer n.Close()
for i := 0; i < 5; i++ {
diff --git a/engine/enq_test.go b/engine/enq_test.go
index bfd1047e..18d4a8bd 100644
--- a/engine/enq_test.go
+++ b/engine/enq_test.go
@@ -276,6 +276,8 @@ func failFunc(task *pb.Task) ([]byte, error) {
}
func TestQueue(t *testing.T) {
+ t.Parallel()
+
n := newTestNet()
defer n.Close()
for i := 0; i < 5; i++ {
@@ -339,6 +341,8 @@ func TestQueue(t *testing.T) {
}
func TestQueue_SameShard(t *testing.T) {
+ t.Parallel()
+
n := newTestNet()
defer n.Close()
for i := 0; i < 5; i++ {
@@ -397,6 +401,8 @@ func TestQueue_SameShard(t *testing.T) {
}
func TestQueue_Fail(t *testing.T) {
+ t.Parallel()
+
n := newTestNet()
defer n.Close()
for i := 0; i < 5; i++ {
@@ -450,6 +456,8 @@ func TestQueue_Fail(t *testing.T) {
}
func TestQueue_Cancel(t *testing.T) {
+ t.Parallel()
+
n := newTestNet()
defer n.Close()
for i := 0; i < 5; i++ {
@@ -551,6 +559,8 @@ func TestQueue_Cancel(t *testing.T) {
// TODO: This does not yet test *failure*!
func TestQueue_IndependentFailure(t *testing.T) {
+ t.Parallel()
+
n := newTestNet()
defer n.Close()
for i := 0; i < 5; i++ {
@@ -630,6 +640,8 @@ func TestQueue_IndependentFailure(t *testing.T) {
}
func TestQuery(t *testing.T) {
+ t.Parallel()
+
n := newTestNet()
defer n.Close()
for i := 0; i < 5; i++ {
--
GitLab