From a0757c7ec629697050b8d1ce4eda9a94c93faf04 Mon Sep 17 00:00:00 2001
From: Seb <sebastien@squareup.com>
Date: Tue, 20 Feb 2024 16:10:55 -0800
Subject: [PATCH] pool size of 1

---
 internal/jobs_test.go | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git a/internal/jobs_test.go b/internal/jobs_test.go
index 439eb99..af0fcad 100644
--- a/internal/jobs_test.go
+++ b/internal/jobs_test.go
@@ -224,7 +224,7 @@ func Test_Consume(t *testing.T) {
 	go func() {
 		jqueue.Consume(ctx, internal.ConsumeParams{
 			Queue:    "q1",
-			PoolSize: 10,
+			PoolSize: 1,
 			Worker: func(ctx context.Context, job *internal.Job) error {
 				q1 <- job.Job
 				if job.Job == "q1-99" {
@@ -243,7 +243,7 @@ func Test_Consume(t *testing.T) {
 	go func() {
 		jqueue.Consume(ctx2, internal.ConsumeParams{
 			Queue:    "q2",
-			PoolSize: 7,
+			PoolSize: 1,
 			Worker: func(ctx context.Context, job *internal.Job) error {
 				q2 <- job.Job
 				if job.Job == "q2-99" {
@@ -357,7 +357,7 @@ func Test_VisibilityTimeout(t *testing.T) {
 	go func() {
 		jqueue.Consume(ctx, internal.ConsumeParams{
 			Queue:             "",
-			PoolSize:          6,
+			PoolSize:          1,
 			VisibilityTimeout: 1,
 			OnEmptySleep:      100 * time.Millisecond,
 			Worker: func(ctx context.Context, job *internal.Job) error {