From 339f99a26191ede59a9eb0de2819cb5efdeb1535 Mon Sep 17 00:00:00 2001
From: nsfisis <nsfisis@gmail.com>
Date: Thu, 8 Aug 2024 00:46:45 +0900
Subject: refactor(backend): wrap taskqueue.processor

---
 backend/taskqueue/worker_server.go | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

(limited to 'backend/taskqueue/worker_server.go')

diff --git a/backend/taskqueue/worker_server.go b/backend/taskqueue/worker_server.go
index 6dc65d8..317f61c 100644
--- a/backend/taskqueue/worker_server.go
+++ b/backend/taskqueue/worker_server.go
@@ -8,7 +8,7 @@ import (
 
 type WorkerServer struct {
 	server    *asynq.Server
-	processor *processor
+	processor *processorWrapper
 }
 
 func NewWorkerServer(redisAddr string, queries *db.Queries) *WorkerServer {
@@ -18,7 +18,7 @@ func NewWorkerServer(redisAddr string, queries *db.Queries) *WorkerServer {
 		},
 		asynq.Config{},
 	)
-	processor := newProcessor(queries)
+	processor := newProcessorWrapper(newProcessor(queries))
 	return &WorkerServer{
 		server:    server,
 		processor: processor,
-- 
cgit v1.2.3-70-g09d2