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

fix: job issues

Browse Source
This commit is contained in:
Rogee
2024-12-30 19:39:26 +08:00
parent 4a5c1f2624
commit b91d759e77
1 changed files with 13 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
templates/project/pkg/service/queue/river.go.tpl
View File

@@ -68,17 +68,19 @@ func Serve(cmd *cobra.Command, args []string) error {
WithField("duration", cronJob.Periodic().Seconds()). WithField("duration", cronJob.Periodic().Seconds()).
Info("registering cron job") Info("registering cron job")
client.PeriodicJobs().Add(river.NewPeriodicJob( for _, jobArgs := range cronJob.JobArgs() {
client.PeriodicJobs().Add(
river.NewPeriodicJob(
river.PeriodicInterval(cronJob.Periodic()), river.PeriodicInterval(cronJob.Periodic()),
func() (river.JobArgs, *river.InsertOpts) { func() (river.JobArgs, *river.InsertOpts) {
return cronJob.JobArgs(), cronJob.InsertOpts() return jobArgs, cronJob.InsertOpts()
}, },
&river.PeriodicJobOpts{ &river.PeriodicJobOpts{
RunOnStart: cronJob.RunOnStart(), RunOnStart: cronJob.RunOnStart(),
}, },
), ),
) )
}
} }
if err := client.Start(ctx); err != nil { if err := client.Start(ctx); err != nil {