rogee/atomctl
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix: job driver

Browse Source
This commit is contained in:
rogeecn
2025-03-17 11:52:52 +08:00
parent e595ecb7af
commit f1c0cf236f
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
templates/project/providers/job/provider.go.tpl
View File

@@ -76,7 +76,7 @@ func (q *Job) Client() (*river.Client[pgx.Tx], error) {
if q.client == nil { if q.client == nil {
var err error var err error
q.client, err = river.NewClient(q.Driver, &river.Config{ q.client, err = river.NewClient(q.driver, &river.Config{
Workers: q.Workers, Workers: q.Workers,
Queues: map[string]river.QueueConfig{ Queues: map[string]river.QueueConfig{
QueueHigh: {MaxWorkers: 10}, QueueHigh: {MaxWorkers: 10},