diff --git a/engine/debug_test.go b/engine/debug_test.go
index 73da58f56cd03b42abec96a8a903601600e68ba5..36e17637d56b0907d002b90181450b11597d63db 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 bfd1047e4b25c02532d3f19fa4f4de31b610fc54..18d4a8bddb4c17068bfb69135f7d9222846100ba 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++ {