From ee1d1d32d4c8fea45ea39eb5b43be5e86cebaefc Mon Sep 17 00:00:00 2001 From: Andre Medeiros Date: Thu, 3 Nov 2022 10:30:50 -0400 Subject: [PATCH] try again with a queue specific redis connection --- internal/cmd/worker.go | 8 +++++++- 1 file changed, 7 insertions(+), 1 deletion(-) diff --git a/internal/cmd/worker.go b/internal/cmd/worker.go index 5d4a792..1db99be 100644 --- a/internal/cmd/worker.go +++ b/internal/cmd/worker.go @@ -63,7 +63,13 @@ func WorkerCmd(ctx context.Context) *cobra.Command { } defer redis.Close() - queue, err := cmdutil.NewQueueClient(logger, redis, "worker") + qredis, err := cmdutil.NewRedisClient(ctx, poolSize) + if err != nil { + return err + } + defer qredis.Close() + + queue, err := cmdutil.NewQueueClient(logger, qredis, "worker") if err != nil { return err }