diff options
| author | nsfisis <nsfisis@gmail.com> | 2024-08-08 00:46:45 +0900 |
|---|---|---|
| committer | nsfisis <nsfisis@gmail.com> | 2024-08-08 04:02:37 +0900 |
| commit | 339f99a26191ede59a9eb0de2819cb5efdeb1535 (patch) | |
| tree | 37d9437c6e6865acfc5f6edd06f27b8be2a7b22b /backend/taskqueue/worker_server.go | |
| parent | c173778cefd66e5259ad75c9399a95c03ce5fa91 (diff) | |
| download | phperkaigi-2025-albatross-339f99a26191ede59a9eb0de2819cb5efdeb1535.tar.gz phperkaigi-2025-albatross-339f99a26191ede59a9eb0de2819cb5efdeb1535.tar.zst phperkaigi-2025-albatross-339f99a26191ede59a9eb0de2819cb5efdeb1535.zip | |
refactor(backend): wrap taskqueue.processor
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, |