diff --git a/apps/api/cmd/email_worker/main.go b/apps/api/cmd/email_worker/main.go index 57f43db0..3364213a 100644 --- a/apps/api/cmd/email_worker/main.go +++ b/apps/api/cmd/email_worker/main.go @@ -3,6 +3,7 @@ package main import ( "fmt" "log" + "time" "github.com/hibiken/asynq" "github.com/swamphacks/core/apps/api/internal/config" @@ -24,10 +25,15 @@ func main() { srv := asynq.NewServer( redisOpt, asynq.Config{ - Concurrency: 10, + Concurrency: 1, Queues: map[string]int{ - "email": 10, + "email": 1, }, + TaskCheckInterval: 60 * time.Second, + DelayedTaskCheckInterval: 2 * time.Minute, + HealthCheckInterval: 2 * time.Minute, + JanitorInterval: time.Hour, + JanitorBatchSize: 100, }, )