feat: update job timeout to 30

This commit is contained in:
Rogee
2025-05-06 11:45:45 +08:00
parent 52c2b61ebf
commit dcc019969f

View File

@@ -78,7 +78,7 @@ func (q *Job) Client() (*river.Client[pgx.Tx], error) {
var err error
q.client, err = river.NewClient(q.driver, &river.Config{
Workers: q.Workers,
JobTimeout: time.Minute * 10,
JobTimeout: time.Minute * 30,
Queues: map[string]river.QueueConfig{
QueueHigh: {MaxWorkers: 10},
QueueDefault: {MaxWorkers: 10},