From f1c0cf236ff86baa4ab09db032955376d5fcbfcd Mon Sep 17 00:00:00 2001 From: rogeecn Date: Mon, 17 Mar 2025 11:52:52 +0800 Subject: [PATCH] fix: job driver --- templates/project/providers/job/provider.go.tpl | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/templates/project/providers/job/provider.go.tpl b/templates/project/providers/job/provider.go.tpl index 5e9c502..2e24ca6 100644 --- a/templates/project/providers/job/provider.go.tpl +++ b/templates/project/providers/job/provider.go.tpl @@ -76,7 +76,7 @@ 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{ + q.client, err = river.NewClient(q.driver, &river.Config{ Workers: q.Workers, Queues: map[string]river.QueueConfig{ QueueHigh: {MaxWorkers: 10},