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

fix: issues

Browse Source
This commit is contained in:
Rogee
2025-03-15 21:35:16 +08:00
parent 69846cdf98
commit 831dfff3d6
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
templates/project/app/service/queue/river.go.tpl
View File

@@ -58,7 +58,7 @@ func Serve(cmd *cobra.Command, args []string) error {
if err := svc.Job.Start(ctx); err != nil { if err := svc.Job.Start(ctx); err != nil {
return err return err
} }
defer svc.Job.Close(ctx) defer svc.Job.Close()
<-ctx.Done() <-ctx.Done()
return nil return nil