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},