diff --git a/modules/queue/queue_disk_channel_test.go b/modules/queue/queue_disk_channel_test.go
index 5049fb58d..93061bffc 100644
--- a/modules/queue/queue_disk_channel_test.go
+++ b/modules/queue/queue_disk_channel_test.go
@@ -52,7 +52,7 @@ func TestPersistableChannelQueue(t *testing.T) {
 	err = queue.Push(&test1)
 	assert.NoError(t, err)
 	go func() {
-		err = queue.Push(&test2)
+		err := queue.Push(&test2)
 		assert.NoError(t, err)
 	}()
 
diff --git a/modules/queue/queue_disk_test.go b/modules/queue/queue_disk_test.go
index 789b6c3e6..edaed49a5 100644
--- a/modules/queue/queue_disk_test.go
+++ b/modules/queue/queue_disk_test.go
@@ -65,7 +65,7 @@ func TestLevelQueue(t *testing.T) {
 	err = queue.Push(&test1)
 	assert.NoError(t, err)
 	go func() {
-		err = queue.Push(&test2)
+		err := queue.Push(&test2)
 		assert.NoError(t, err)
 	}()