From 60d62da5722cd9cac7ca3ec5126840c3ce55b7ed Mon Sep 17 00:00:00 2001 From: keven1024 Date: Wed, 3 Jun 2026 17:05:10 +0800 Subject: [PATCH] feat(worker): initialize Asynq in main function for task processing --- worker/main.go | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/worker/main.go b/worker/main.go index f3026a6..e98dfcd 100644 --- a/worker/main.go +++ b/worker/main.go @@ -28,6 +28,10 @@ func main() { logger.Fatal("redis init failed", zap.Error(err)) panic(err) } + if err := utils.InitAsynq(); err != nil { + logger.Fatal("asynq init failed", zap.Error(err)) + panic(err) + } if err := i18n.Init(); err != nil { log.Fatalf("failed to init i18n: %v", err)