diff --git a/templates/project/app/service/queue/river.go.tpl b/templates/project/app/service/queue/river.go.tpl index d9569b1..98c43d1 100644 --- a/templates/project/app/service/queue/river.go.tpl +++ b/templates/project/app/service/queue/river.go.tpl @@ -58,7 +58,7 @@ func Serve(cmd *cobra.Command, args []string) error { if err := svc.Job.Start(ctx); err != nil { return err } - defer svc.Job.Close(ctx) + defer svc.Job.Close() <-ctx.Done() return nil