From 52c2b61ebf7b9e55fac542ef75648cdffc0bb8d2 Mon Sep 17 00:00:00 2001 From: Rogee Date: Tue, 6 May 2025 11:45:27 +0800 Subject: [PATCH] feat: update job timeout to 20 minutes --- backend/providers/job/provider.go | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/backend/providers/job/provider.go b/backend/providers/job/provider.go index d43b02c..cd19551 100644 --- a/backend/providers/job/provider.go +++ b/backend/providers/job/provider.go @@ -3,6 +3,7 @@ package job import ( "context" "sync" + "time" "quyun/providers/postgres" @@ -76,7 +77,8 @@ func (q *Job) Client() (*river.Client[pgx.Tx], error) { if q.client == nil { var err error q.client, err = river.NewClient(q.driver, &river.Config{ - Workers: q.Workers, + Workers: q.Workers, + JobTimeout: time.Minute * 10, Queues: map[string]river.QueueConfig{ QueueHigh: {MaxWorkers: 10}, QueueDefault: {MaxWorkers: 10},