Mark tests as parallelizable

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++ {

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++ {