From 7a115349cb60958d7d6f6a58305a391104d6cf7f Mon Sep 17 00:00:00 2001 From: a Date: Wed, 3 Jul 2024 21:11:02 -0500 Subject: [PATCH 1/2] Update periodic_job.go --- periodic_job.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/periodic_job.go b/periodic_job.go index 48c3c6e7..2ac2cdf1 100644 --- a/periodic_job.go +++ b/periodic_job.go @@ -180,10 +180,10 @@ func (b *PeriodicJobBundle) toInternal(periodicJob *PeriodicJob) *maintenance.Pe if periodicJob.opts != nil { opts = periodicJob.opts } - args, options := periodicJob.constructorFunc() return &maintenance.PeriodicJob{ ConstructorFunc: func() (*riverdriver.JobInsertFastParams, *dbunique.UniqueOpts, error) { + args, options := periodicJob.constructorFunc() return insertParamsFromConfigArgsAndOptions(&b.periodicJobEnqueuer.Archetype, b.clientConfig, args, options) }, RunOnStart: opts.RunOnStart, From 77ee9f557cc215b2b04dc01eaf2592c09885f353 Mon Sep 17 00:00:00 2001 From: a Date: Wed, 3 Jul 2024 21:13:08 -0500 Subject: [PATCH 2/2] a line --- periodic_job.go | 1 - 1 file changed, 1 deletion(-) diff --git a/periodic_job.go b/periodic_job.go index 2ac2cdf1..38d01eb9 100644 --- a/periodic_job.go +++ b/periodic_job.go @@ -180,7 +180,6 @@ func (b *PeriodicJobBundle) toInternal(periodicJob *PeriodicJob) *maintenance.Pe if periodicJob.opts != nil { opts = periodicJob.opts } - return &maintenance.PeriodicJob{ ConstructorFunc: func() (*riverdriver.JobInsertFastParams, *dbunique.UniqueOpts, error) { args, options := periodicJob.constructorFunc()