diff options
Diffstat (limited to 'backend/taskqueue/worker_server.go')
| -rw-r--r-- | backend/taskqueue/worker_server.go | 4 |
1 files changed, 2 insertions, 2 deletions
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, |